multiprocessing

Pool

class multiprocessing.Pool(processes=cpu_count())

pool = Pool(2)

with Pool() as pool:

    pool.map(func, args)

class 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()

cpu_count()

multiprocessing.cpu_count()

Возвращает количество ядер процессора

cpu_count()
# 4

current_process

multiprocessing.current_process()

Возвращает текущий процесс