您好,登錄后才能下訂單哦!
本篇文章為大家展示了Python中多進(jìn)程的原理是什么,內(nèi)容簡明扼要并且容易理解,絕對(duì)能使你眼前一亮,通過這篇文章的詳細(xì)介紹希望你能有所收獲。
進(jìn)程是程序在計(jì)算機(jī)上的一次執(zhí)行活動(dòng)。當(dāng)你運(yùn)行一個(gè)程序,你就啟動(dòng)了一個(gè)進(jìn)程。顯然,程序是死的(靜態(tài)的),進(jìn)程是活的(動(dòng)態(tài)的)。進(jìn)程可以分為系統(tǒng)進(jìn)程和用戶進(jìn)程。凡是用于完成操作系統(tǒng)的各種功能的進(jìn)程就是系統(tǒng)進(jìn)程,它們就是處于運(yùn)行狀態(tài)下的操作系統(tǒng)本身;所有由你啟動(dòng)的進(jìn)程都是用戶進(jìn)程。進(jìn)程是操作系統(tǒng)進(jìn)行資源分配的單位。
開啟一個(gè)進(jìn)程
import multiprocessing,time,os def runtask(): time.sleep(2) print("開啟一個(gè)進(jìn)程:%s"%os.getpid()) if __name__ == "__main__": p = multiprocessing.Process(target=runtask,) p.start()
進(jìn)程隊(duì)列
import multiprocessing def runtask(): q.put([42,"python"]) if __name__ == "__main__": q = multiprocessing.Queue() p = multiprocessing.Process(target=runtask,) p.start() print(q.get()) # 打印結(jié)果:[42,"python"]
pipe管道
返回兩個(gè)連接對(duì)象。代表管道的兩端,默認(rèn)雙向通信。
import multiprocessing def runtask(): conn.send("abc") conn.close() if __name__ == "__main__": conn,pconn = multiprocessing.Pipe() p = multiprocessing.Process() p.start() print(pconn.recv()) # 打印結(jié)果:"abc"
Value、Array
共享內(nèi)存有兩個(gè)結(jié)構(gòu),一個(gè)是Value,一個(gè)是Array,這兩個(gè)結(jié)構(gòu)內(nèi)部都實(shí)現(xiàn)了鎖機(jī)制,因此進(jìn)程是安全的。
import multiprocess def runtask(): d.value = 50 for index in range(len(a)): a[index]+=10 if __name__ == "__main__": # 下面的字符"d"、"i"似乎是固定的,換成其他將會(huì)報(bào)錯(cuò)。求大神解釋 d = Value("d",20) a = Array("i",range(10)) p = multiprocessing.Process(target=runtask,) p.start() p.join() # 等待進(jìn)程執(zhí)行完畢 print(d.value,a[:]) # 打印結(jié)果: 50.0 [10, 11, 12, 13, 14, 15, 16, 17, 18, 19]
Manager
Python實(shí)現(xiàn)多進(jìn)程之間通信除了Queue(隊(duì)列)、Pipe(管道)和Value-Array之外,還提供了更高層次的封裝。Manager支持的類型非常多,如:list, dict, Namespace, Lock, RLock, Semaphore, BoundedSemaphore, Condition, Event, Queue, Value 和 Array 用法如下:
import multiprocessing def runtask(): d["name"] = "laowang" l.reverse() if __name__ == "__main__": with multiprocessing.Manager() as manager: d = manager.dict() l = manager.list(range(10)) p = multiprocessing.Process(target=runtask,) p.start() p.join() # 等待進(jìn)程執(zhí)行完畢 print(d,l) # 打印結(jié)果:{'name': 'laowang'} [9, 8, 7, 6, 5, 4, 3, 2, 1, 0]
進(jìn)程池Pool
Pool 是進(jìn)程池,進(jìn)程池能夠管理一定的進(jìn)程,當(dāng)有空閑進(jìn)程時(shí),則利用空閑進(jìn)程完成任務(wù),直到所有任務(wù)完成為止
import multiprocessing def runtask(): pass def callBackTask(arg): # 回調(diào)函數(shù)必須要有一個(gè)形參,否則將報(bào)錯(cuò) print("執(zhí)行回調(diào)函數(shù)",arg) if __name__ == "__main__": pool = multiprocessing.Pool(5) # 設(shè)置進(jìn)程池最大同時(shí)執(zhí)行進(jìn)程數(shù) for index in range(20): pool.apply_async(func=runtask,callback=callBackTask) # 并行的,有回調(diào)方法 # pool.apply(func=runtask,) # 串行的,無回調(diào)函數(shù) pool.close() # 關(guān)閉進(jìn)程池 pool.join() # #調(diào)用join之前,先調(diào)用close函數(shù),否則會(huì)出錯(cuò)。執(zhí)行完close后不會(huì)有新的進(jìn)程加入到pool,join函數(shù)等待所有子進(jìn)程結(jié)束
1、簡單易用,與C/C++、Java、C# 等傳統(tǒng)語言相比,Python對(duì)代碼格式的要求沒有那么嚴(yán)格;2、Python屬于開源的,所有人都可以看到源代碼,并且可以被移植在許多平臺(tái)上使用;3、Python面向?qū)ο?,能夠支持面向過程編程,也支持面向?qū)ο缶幊蹋?、Python是一種解釋性語言,Python寫的程序不需要編譯成二進(jìn)制代碼,可以直接從源代碼運(yùn)行程序;5、Python功能強(qiáng)大,擁有的模塊眾多,基本能夠?qū)崿F(xiàn)所有的常見功能。
上述內(nèi)容就是Python中多進(jìn)程的原理是什么,你們學(xué)到知識(shí)或技能了嗎?如果還想學(xué)到更多技能或者豐富自己的知識(shí)儲(chǔ)備,歡迎關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。