multiprocessing¶
Pool¶
- class
multiprocessing.
Pool
(processes=cpu_count())¶ pool = Pool(2) with Pool() as pool: pool.map(func, args)
-
apply
(func, args)¶ result = [pool.apply(some_func, args=(num, )) for num in [1, 2, 3]]
-
apply_async
(func, args)¶ Возвращает
ApplyResult
result = [pool.apply_async(some_func, args=(num, )) for num in [1, 2, 3]]
-
close
()¶ pool.close()
-
join
()¶ pool.join()
-
map
(func, iterable)¶ pool.map(some_func, [1,2,3])
-
starmap
()¶ pool.starmap(sum, [(1, 6), (2, 7)])
-
starmap_async
()¶
-