初始化Pool時，可以指定?個最大進程池，當有新進程提交時，如果池還沒有滿，那么就會創建新進程請求；但如果池中達到最大值，那么就會等待，待池中有進程結束，新進程來執行。

非阻塞式：apply_async(func[,????????args[,????????kwds]])????????：

一個程序結束運行新程序，幾個任務同時進行

?

阻塞式：apply(func[,????????args[,????????kwds]])：

進程有先后順序

?

close()：關閉Pool，使其不再接受新的任務；

terminate()：不管任務是否完成，立刻終止，但存在延遲；

join()：主進程阻塞，等待子進程退出，必須在close或terminate之后

?

非阻塞方法：

from multiprocessing import Pool

import time

import os

?

def task(num):

??? """定義的任務代碼"""

??? print("子進程：pid=%d 開始執行任務num=%d" % (os.getpid(), num))

??? time.sleep(1)

??? print("子進程：pid=%d 結束執行任務num=%d" % (os.getpid(), num))

?

pool = Pool(4)? # 創建進程池對象，參數表明這個進程池中包含4個子進程

?

for i in range(10)

?? ?pool.apply_async(task, (i,))? # 向進程池添加任務 非阻塞方法

?

print("主進程：所有任務都已交給進程池去做")

?

pool.close()? # 關閉進程池對象，表示不能再向進程池中添加新的任務

?

pool.join()? # 回收進程池資源

?

?阻塞方法：

from multiprocessing import Pool

import time

import os

?

def task(num):

??? """定義的任務代碼"""

??? print("子進程：pid=%d 開始執行任務num=%d" % (os.getpid(), num))

??? time.sleep(1)

??? print("子進程：pid=%d 結束執行任務num=%d" % (os.getpid(), num))

?

?

pool = Pool(4)? # 創建進程池對象，參數表明這個進程池中包含4個子進程

?

for i in range(10):

???pool.apply(task, (i,))? # 向進程池添加任務 阻塞方法

?

print("主進程：所有任務都已交給進程池去做")

?

pool.close()? # 關閉進程池對象，表示不能再向進程池中添加新的任務

?

pool.join()? # 回收進程池資源

?

總結

以上是生活随笔為你收集整理的python中的进程池Pool的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。