新聞中心
說(shuō)明

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


咨詢
建站咨詢
