進(jìn)程鎖進(jìn)程池

多進(jìn)程鎖
frommultiprocessingimportProcess, Lock

deff(l, i):
    l.acquire()
   try:
       print('hello world', i)
   finally:
        l.release()

if__name__ =='__main__':
    lock = Lock()

   fornuminrange(100):
        Process(target=f,args=(lock, num)).start()

10年積累的成都網(wǎng)站建設(shè)、成都網(wǎng)站設(shè)計(jì)經(jīng)驗(yàn)，可以快速應(yīng)對(duì)客戶對(duì)網(wǎng)站的新想法和需求。提供各種問(wèn)題對(duì)應(yīng)的解決方案。讓選擇我們的客戶得到更好、更有力的網(wǎng)絡(luò)服務(wù)。我雖然不認(rèn)識(shí)你，你也不認(rèn)識(shí)我。但先網(wǎng)站設(shè)計(jì)后付款的網(wǎng)站建設(shè)流程，更有西湖免費(fèi)網(wǎng)站建設(shè)讓你可以放心的選擇與我們合作。

 

多進(jìn)程池
from multiprocessingimportProcess, Pool
importtime,os

defFoo(i):
    time.sleep(2)
   print("in process:",os.getpid())
   returni +100#返回給callback的Bar

defBar(arg):
   print('-->exec done:', arg,os.getpid())

if__name__=="__main__":
    pool=Pool(processes=5)#允許進(jìn)程池里同時(shí)放入5個(gè)進(jìn)程
   print("主進(jìn)程:",os.getpid())
   foriinrange(10):#callback主進(jìn)程回調(diào) 子進(jìn)程每執(zhí)行完一個(gè)func=Foo, args=(i,)，主進(jìn)程在回調(diào)一次Bar
       pool.apply_async(func=Foo,args=(i,),callback=Bar)#異步執(zhí)行 并行
        #pool.apply(func=Foo, args=(i,))#同步執(zhí)行 串行 不支持callback

   print('end')
    pool.close()
    pool.join()#進(jìn)程池中進(jìn)程執(zhí)行完畢后再關(guān)閉，如果注釋，那么程序直接關(guān)閉。

網(wǎng)頁(yè)題目：進(jìn)程鎖進(jìn)程池
URL分享：http://bm7419.com/article18/pscpgp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站策劃、網(wǎng)站收錄、自適應(yīng)網(wǎng)站、品牌網(wǎng)站設(shè)計(jì)、微信小程序、企業(yè)建站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)