Multiprocessing

© getcodify.com

由於語法渲染問題而影響閱讀體驗， 請移步博客閱讀～
本文GitPage地址

Multiprocessing

Quick Start

import multiprocessing as mp
from time import sleep
def echo(i):
  '''Working Function for cycle'''
  sleep(i)
  print(i)
def multicore(Pool=10):
  pool = mp.Pool(processes=Pool)
  for i in range(10):
    # Working function "echo" and the arg 'i'
    multi_res = [pool.apply_async(echo,(i,))]
  pool.close()
  pool.join()
if __name__ == '__main__':
  multicore()

With Return

Cite: StackoverFlow

import multiprocessing as mp
def worker(procnum, return_dict):
    '''worker function'''
    print (str(procnum) + ' represent!')
    return_dict[procnum] = procnum
if __name__ == '__main__':
    manager = mp.Manager()
    return_dict = manager.dict()
    jobs = []
    for i in range(5):
        p = mp.Process(target=worker, args=(i,return_dict))
        jobs.append(p)
        p.start()
    for proc in jobs:
        proc.join()
    print (return_dict.values())
for i in return_dict.values():
  print(i)

Enjoy~

本文由Python腳本GitHub/語雀自動更新

由於語法渲染問題而影響閱讀體驗， 請移步博客閱讀～
本文GitPage地址

GitHub: Karobben
Blog:Karobben
BiliBili:史上最不正經的生物狗