進程池的難點，python進程池必須手動關閉

2023-11-12 阅读 28 评论 0

摘要：情況 python3.5在用進程池的時候使用了with def f(x):time.sleep(1)return x*xif __name__ == '__main__':process = []pool = Pool(processes=4)with pool:for j in range(8*4):result = pool.apply_async(f, (j,))process.append(result)#

情況

python3.5在用進程池的時候使用了with

def f(x):time.sleep(1)return x*xif __name__ == '__main__':process = []pool = Pool(processes=4)with pool:for j in range(8*4):result = pool.apply_async(f, (j,))process.append(result)# pool.close()pool.join()for i in process:print(i.get())

解決方法

把with換成手動close就行

join()?
等待工作進程結束。調用 join() 前必須先調用 close() 或者 terminate() 。

    for j in range(8*4):result = pool.apply_async(f, (j,))process.append(result)pool.close()pool.join()

刪除sleep、get()方法放到里邊

def f(x):return x*xif __name__ == '__main__':process = []with Pool(processes=4) as pool:for j in range(8):result = pool.apply_async(f, (j,))process.append(result.get())pool.join()for i in process:print(i)