from multiprocessing import Pool # 導入進程池模塊
import os # 導入系統(tǒng)模塊
import time # 導入時間模塊
import random
def to_work(num):
# 打印進程號
print("----開始執(zhí)行任務%d,進程的pid為%d,父進程的pid為%d----" % (num, os.getpid(), os.getppid()))
# 模擬延時 random.random() 生成0-1之間的數
time.sleep(random.random())
print("第%d號進程完成任務%d第一階段" % (os.getpid(), num))
time.sleep(random.random())
print("第%d號進程完成任務%d第二階段" % (os.getpid(), num))
time.sleep(random.random())
print("第%d號進程完成任務%d第三階段" % (os.getpid(), num))
time.sleep(random.random())
print("----任務%d執(zhí)行完畢----" % (num))
def main():
# 創(chuàng)建一個最多開啟3進程的進程池
po = Pool(3)
# 將5個任務添加到進程池
for i in range(1, 6):
# async非堵塞添加,to_work為參數名,i為傳遞的參數,單個參數一定要加逗號!一定要加逗號!一定要加逗號!
po.apply_async(to_work, (i,))
print("----開始----")
# 關閉進程池,不再接收新的任務,開始執(zhí)行任務
po.close()
# 主進程等待所有子進程結束
po.join()
print("----結束----")
if __name__ == "__main__":
main()
Python多任務代碼示例
?著作權歸作者所有,轉載或內容合作請聯系作者
- 文/潘曉璐 我一進店門，熙熙樓的掌柜王于貴愁眉苦臉地迎上來桃焕，“玉大人剑肯，你說我怎么就攤上這事」厶茫” “怎么了让网？”我有些...
- 正文 為了忘掉前任因篇，我火速辦了婚禮泞辐，結果婚禮上，老公的妹妹穿的比我還像新娘竞滓。我一直安慰自己咐吼，他們只是感情好，可當我...
- 文/花漫 我一把揭開白布商佑。 她就那樣靜靜地躺著锯茄，像睡著了一般。 火紅的嫁衣襯著肌膚如雪茶没。 梳的紋絲不亂的頭發(fā)上肌幽，一...
- 文/蒼蘭香墨 我猛地睜開眼涣易，長吁一口氣：“原來是場噩夢啊……” “哼画机！你這毒婦竟也來了？” 一聲冷哼從身側響起新症，我...
- 正文 年R本政府宣布咕别，位于F島的核電站，受9級特大地震影響写穴，放射性物質發(fā)生泄漏惰拱。R本人自食惡果不足惜，卻給世界環(huán)境...
- 文/蒙蒙 一啊送、第九天 我趴在偏房一處隱蔽的房頂上張望偿短。 院中可真熱鬧，春花似錦删掀、人聲如沸翔冀。這莊子的主人今日做“春日...
- 文/蒼蘭香墨 我抬頭看了看天上的太陽。三九已至搬瑰，卻和暖如春款票，著一層夾襖步出監(jiān)牢的瞬間，已是汗流浹背泽论。 一陣腳步聲響...
推薦閱讀更多精彩內容
- 需求 目標：一套代碼分成不同的分支版本雏吭，在同一個工程下管理這幾個版本。 多個分支版本之間陪踩，通常有以下異同： 不同版...
- 一杖们、實例變量+復合操作（read-set-write） count值不等于10000000 二、成員變量+復合操作...
- python多線程編程特別適用于完成相互獨立的任務肩狂，同時進行摘完，相互之間沒有依賴性。比如傻谁，下面我們介紹的從網站中查詢...
