python建立程序池
阿新 • • 發佈:2020-12-20
python建立程序池
# -*- coding:UTF-8 -*-
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))
if __name__ == '__main__':
po = Pool(2) #定義一個程序池,最大程序數為3
for i in range(0, 10):
# Pool().apply_async(呼叫的目標,(傳遞給目標的引數元祖,))
# 每次迴圈將會用空閒的子程序去呼叫目標
po.apply_async(worker, (i,))
print('開始')
po.close() #關閉程序池,關閉後po不在接收新的請求
po. join() #等待po中所有子程序執行完畢,必須放在close語句之後
print('結束')
執行結果如下: