python 程序池Pool詳情

2022-09-23 11:24:08 字數 1406 閱讀 6486

當需要建立的子程序數量不多時,可以直接利用multiprocessing中的process動態成生多個程序,但如果是上百甚至上千個目標,手動的去建立程序的工作量巨大,此時就可以用到multiprocessing模組提供的pool方法。

初始化pool時,可以指定乙個最大程序數,當有新的請求提交到pool中時,如果池還沒有滿,那麼就會建立乙個新的程序用來執行該請求;但如果池中的程序數已經達到指定的最大值,那麼該請求就會等待,直到池中有程序結束,才會建立新的程序來執行,請看下面的例項:

from multiprocessing import pool

import os,time,random

def worker(msg):

t_start = time.time()

print("%s開始執行,程序號為%d"%(msg,os.getpid()))

#random.random()隨機生成0~1之間的浮點數

time.sleep(random.random()*2)

t_stop = time.time()

print(msg,"執行完畢,耗時%0.2f"%(t_stop-t_start))

po=pool(3) #定義乙個程序池,最大程序數3

for i in range(0,10):

#pool.apply_async(要呼叫的目標,(傳遞給目標的引數元祖,))

#每次迴圈將會用空閒出來的子程序去呼叫目標

po.apply_async(worker,(i,))

print("----start----")

po.close() #關閉程序池,關閉後po不再接收新的請求

po.join() #等待po中所有子程序執行完成,必須放在close語句之後

print("-----end-----")執行結果:----start----

0開始執行,程序號為21466

1開始執行,程序號為21468

2開始執行,程序號為21467

0 執行完畢,耗時1.01

3開始執行,程序號為21466

2 執行完畢,耗時1.24

4開始執行,程序號為21467

3 執行完畢,耗時0.56

5開始執行,程序號為21466

1 執行完畢,耗時1.68

6開始執行,程序號為21468

4 執行完畢,耗時0.67

7開始執行,程序號為21467

5 執行完畢,耗時0.83

8開始執行,程序號為21466

6 執行完畢,耗時0.75

9開始執行,程序號為21468

7 執行完畢,耗時1.03

8 執行完畢,耗時1.05

9 執行完畢,耗時1.69

-----end-----multiprocessing.pool常用函式解析:

Python多程序 程序池pool

from multiprocessing import process,pool import time defselect time.sleep 1 print time.ctime return 這是每個進行執行完後返回的值,該值會會被 callback函式接收 def foo args pri...

Python多程序4 程序池 Pool

學習 分類目錄 多程序 是multiprocessing模組下的乙個類,是一種建立多程序的更加簡便的方式,可以更加方便的分配任務與傳遞引數。pool mp.pool processes 6 生成程序池 pool的兩個任務分配的函式 map 函式名,引數列表的列表 所謂的引數列表的列表是把所有的任務的...

python 程序池pool簡單使用

平常會經常用到多程序,可以用程序池pool來進行自動控制程序,下面介紹一下pool的簡單使用。需要主動是,在windows上要想使用程序模組,就必須把有關程序的 寫if name main 語句的下面,才能正常使用windows下的程序模組。unix linux下則不需要。pool類 pool類可以...