今天小編給大家分享一下python Pool常用函數(shù)是什么的相關知識點,內(nèi)容詳細,邏輯清晰,相信大部分人都還太了解這方面的知識,所以分享這篇文章給大家參考一下,希望大家閱讀完這篇文章后有所收獲,下面我們一起來了解一下吧。
成都創(chuàng)新互聯(lián)服務項目包括富順網(wǎng)站建設、富順網(wǎng)站制作、富順網(wǎng)頁制作以及富順網(wǎng)絡營銷策劃等。多年來,我們專注于互聯(lián)網(wǎng)行業(yè),利用自身積累的技術優(yōu)勢、行業(yè)經(jīng)驗、深度合作伙伴關系等,向廣大中小型企業(yè)、政府機構等提供互聯(lián)網(wǎng)行業(yè)的解決方案,富順網(wǎng)站推廣取得了明顯的社會效益與經(jīng)濟效益。目前,我們服務的客戶以成都為中心已經(jīng)輻射到富順省份的部分城市,未來相信會繼續(xù)擴大服務區(qū)域并繼續(xù)獲得客戶的支持與信任!
說明
1、apply_async(func[,args[,kwds]):使用非堵塞調(diào)用func(并行執(zhí)行,堵塞方式必須等待上一個過程退出才能執(zhí)行下一個過程),args是傳輸給func的參數(shù)列表,kwds是傳輸給func的關鍵詞參數(shù)列表。
2、close():關閉Pool,使之不再接受新任務。
3、terminate():無論任務是否完成,都要立即終止。
4、join():主進程堵塞,等待子進程退出,必須在close或terminate之后使用。
實例
#coding: utf-8 import multiprocessing import time def func(msg): print("msg:", msg) time.sleep(3) print("end") if __name__ == "__main__": cores = multiprocessing.cpu_count() pool = multiprocessing.Pool(processes=cores) print("Adding tasks...") for i in range(cores): msg = "hello %d" %(i) pool.apply_async(func, (msg, )) #維持執(zhí)行的進程總數(shù)為processes,當一個進程執(zhí)行完畢后會添加新的進程進去 print("Starting tasks...") pool.close() pool.join() #調(diào)用join之前,先調(diào)用close函數(shù),否則會出錯。執(zhí)行完close后不會有新的進程加入到pool,join函數(shù)等待所有子進程結束 print("Sub-process(es) done.")
以上就是“python Pool常用函數(shù)是什么”這篇文章的所有內(nèi)容,感謝各位的閱讀!相信大家閱讀完這篇文章都有很大的收獲,小編每天都會為大家更新不同的知識,如果還想學習更多的知識,請關注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
網(wǎng)站名稱:pythonPool常用函數(shù)是什么
URL標題:http://jinyejixie.com/article22/ggihjc.html
成都網(wǎng)站建設公司_創(chuàng)新互聯(lián),為您提供自適應網(wǎng)站、關鍵詞優(yōu)化、網(wǎng)站營銷、標簽優(yōu)化、用戶體驗、App設計
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)