File: pool-test.py

package info (click to toggle)
scalene 1.5.54-2
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid
  • size: 15,980 kB
  • sloc: cpp: 22,870; python: 14,493; javascript: 12,297; ansic: 817; makefile: 196; sh: 45
file content (18 lines) | stat: -rwxr-xr-x 359 bytes parent folder | download 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
 
import multiprocessing

# import logging
# log = multiprocessing.get_logger()
# log.setLevel(logging.DEBUG)
# log.addHandler(logging.StreamHandler())
from multiprocessing import Pool


def f(x):
    print("Start")
    return [i for i in range(1000000)]


if __name__ == "__main__":
    with Pool(5) as p:
        q = p.map(f, [1, 2, 3])
        print(len(q))