建站
咨詢
售后
建站咨詢
新聞中心
這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
創(chuàng)新互聯(lián)Python教程：python中進程池Pool的初始化
說明
成都創(chuàng)新互聯(lián)專注為客戶提供全方位的互聯(lián)網(wǎng)綜合服務(wù)，包含不限于成都網(wǎng)站建設(shè)、成都網(wǎng)站設(shè)計、金昌網(wǎng)絡(luò)推廣、重慶小程序開發(fā)、金昌網(wǎng)絡(luò)營銷、金昌企業(yè)策劃、金昌品牌公關(guān)、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運營等，從售前售中售后，我們都將竭誠為您服務(wù)，您的肯定，是我們最大的嘉獎；成都創(chuàng)新互聯(lián)為所有大學(xué)生創(chuàng)業(yè)者提供金昌建站搭建服務(wù)，24小時服務(wù)熱線：028-86922220，官方網(wǎng)址：www.cdcxhl.com
1、初始化Pool時，可以指定流程數(shù)。
2、當(dāng)新請求提交到Pool時，如果池未滿，則創(chuàng)建新流程以執(zhí)行該請求。
3、如果池中的流程數(shù)達(dá)到指定的值，則等待該請求，直到池中的流程結(jié)束為止，以之前的流程執(zhí)行新的任務(wù)。
實例
# -*- coding:utf-8 -*-
import os, time, random
from multiprocessing import Pool
def worker(msg):
t_start = time.time()
print("%s開始執(zhí)行,進程號為%d" % (msg,os.getpid()))
# random.random()隨機生成0~1之間的浮點數(shù)
time.sleep(random.random()*2)
t_stop = time.time()
print(msg,"執(zhí)行完畢，耗時%0.2f\n" % (t_stop-t_start))
def main():
po = Pool(3) # 定義一個進程池，進程數(shù)3
for i in range(0,10):
# Pool().apply_async(要調(diào)用的目標(biāo),(傳遞給目標(biāo)的參數(shù)元祖,))
# 每次循環(huán)將會用空閑出來的子進程去調(diào)用目標(biāo)
po.apply_async(worker,(i,))
print("----start----")
po.close() # 關(guān)閉進程池，關(guān)閉后po不再接收新的請求
po.join() # 等待po中所有子進程執(zhí)行完成，必須放在close語句之后
print("-----end-----")
if __name__ == "__main__":
main()以上就是python中進程池Pool的初始化，希望對大家有所幫助。更多編程基礎(chǔ)知識學(xué)習(xí)：python學(xué)習(xí)網(wǎng)
本文教程操作環(huán)境：windows7系統(tǒng)、Python 3.9.1，DELL G3電腦。
分享名稱：創(chuàng)新互聯(lián)Python教程：python中進程池Pool的初始化
轉(zhuǎn)載注明：http://m.5511xx.com/article/djejjog.html
