frommultiprocessingimportPoolimporttimeimportosimportrandom**p=Pool(3)**defworker(msg):start_time=time.time()print("開始執(zhí)行進(jìn)程%d-----%s"%(msg,os.getpid()))time.sleep(random.random()*2)stop_time=time.time()print(msg,'耗費(fèi)時間是%0.2f'%(stop_time-start_time))foriinrange(0,10):p.apply_async(worker,(i,))print("-----start-----")p.close()p.join()print("------END-------")為什么p=pool(3)如果寫在defworker(msg)的上面,程序就會報錯呢?如果寫在defworker(msg)的下面就運(yùn)行正常,網(wǎng)上沒找到答案,求大神解答,感謝。
Python創(chuàng)建進(jìn)程池的代碼位置問題
慕運(yùn)維8079593
2019-05-10 08:55:49