multiprocessing.
Pool
(processes=cpu_count())pool = Pool(2)
with Pool() as pool:
pool.map(func, args)
ApplyResult
get
()возвращает значение результата
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
()multiprocessing.
cpu_count
()Возвращает количество ядер процессора
cpu_count()
# 4
multiprocessing.
current_process
()Возвращает текущий процесс