python 多進程

基于官方文檔：

溫宿網(wǎng)站制作公司哪家好，找成都創(chuàng)新互聯(lián)公司！從網(wǎng)頁設計、網(wǎng)站建設、微信開發(fā)、APP開發(fā)、自適應網(wǎng)站建設等網(wǎng)站項目制作，到程序開發(fā)，運營維護。成都創(chuàng)新互聯(lián)公司成立與2013年到現(xiàn)在10年的時間，我們擁有了豐富的建站經(jīng)驗和運維經(jīng)驗，來保證我們的工作的順利進行。專注于網(wǎng)站建設就選成都創(chuàng)新互聯(lián)公司。

日樂購，剛才看到的一個博客，寫的都不太對，還是基于官方的比較穩(wěn)妥

我就是喜歡抄官方的，哈哈

通常我們使用Process實例化一個進程，并調(diào)用 他的 start() 方法啟動它。

這種方法和 Thread 是一樣的。

上圖中，我寫了 p.join() 所以主進程是 等待 子進程執(zhí)行完后，才執(zhí)行 print("運行結(jié)束")

否則就是反過來了（這個不一定，看你的語句了，順序其實是隨機的）例如：

主進加個 sleep

所以不加join() ,其實子進程和主進程是各干各的，誰也不等誰。都執(zhí)行完后，文件運行就結(jié)束了

上面我們用了 os.getpid() 和 os.getppid() 獲取 當前進程，和父進程的id

下面就講一下，這兩個函數(shù)的用法：

os.getpid()

返回當前進程的id

os.getppid()

返回父進程的id。 父進程退出后，unix 返回初始化進程（1）中的一個

windows返回相同的id (可能被其他進程使用了)

這也就解釋了，為啥我上面 的程序運行多次， 第一次打印的parentid 都是 14212 了。

而子進程的父級 process id 是調(diào)用他的那個進程的 id ： 1940

視頻筆記：

多進程：使用大致方法：

參考： 進程通信（pipe和queue）

pool.map （函數(shù)可以有return 也可以共享內(nèi)存或queue） 結(jié)果直接是個列表

poll.apply_async() （同map,只不過是一個進程，返回結(jié)果用 xx.get() 獲得）

報錯：

參考 ：

把 pool = Pool() 放到 if name == " main ": 下面初始化搞定。

結(jié)果：

這個肯定有解釋的

測試多進程計算效果：

進程池運行：

結(jié)果：

普通計算：

我們同樣傳入 1 2 10 三個參數(shù)測試：

其實對比下來開始快了一半的；

我們把循環(huán)里的數(shù)字去掉一個 0；

單進程：

多進程：

兩次測試 單進程/進程池 分別為 0.669 和 0.772 幾乎成正比的。

問題 二：

視圖：

post 視圖里面

Music 類：

直接報錯：

寫在 類里面也 在函數(shù)里用 self.pool 調(diào)用也不行，也是相同的錯誤。

最后 把 pool = Pool 直接寫在 search 函數(shù)里面，奇跡出現(xiàn)了：

前臺也能顯示搜索的音樂結(jié)果了

總結(jié)一點，進程這個東西，最好 寫在 直接運行的函數(shù)里面，而不是 一個函數(shù)跳來跳去。因為最后可能 是在子進程的子進程運行的，這是不許的，會報錯。

還有一點，多進程運行的函數(shù)對象，不能是 lambda 函數(shù)。也許lambda 虛擬，在內(nèi)存？？

使用 pool.map 子進程 函數(shù)報錯，導致整個 pool 掛了:

參考：

主要你要，對函數(shù)內(nèi)部捕獲錯誤，而不能讓異常拋出就可以了。

關(guān)于map 傳多個函數(shù)參數(shù)

我一開始，就是正常思維，多個參數(shù)，搞個元祖，讓參數(shù)一一對應不就行了：

報錯：

參考：

普通的 process 當讓可以穿多個參數(shù)，map 卻不知道咋傳的。

apply_async 和map 一樣，不知道咋傳的。

最簡單的方法：

使用 starmap 而不是 map

結(jié)果：

子進程結(jié)束

1.8399453163146973

成功拿到結(jié)果了

關(guān)于map 和 starmap 不同的地方看源碼：

關(guān)于apply_async() ,我沒找到多參數(shù)的方法，大不了用 一個迭代的 starmap 實現(xiàn)。哈哈

關(guān)于 上面源碼里面有 itertools.starmap

itertools 用法參考：

有個問題，多進程最好不要使用全部的 cpu , 因為這樣可能影響其他任務，所以 在進程池 添加 process 參數(shù) 指定，cpu 個數(shù)：

上面就是預留了 一個cpu 干其他事的

后面直接使用 Queue 遇到這個問題：

解決：

Manager().Queue() 代替 Queue()

因為 queue.get() 是堵塞型的，所以可以提前判斷是不是 空的，以免堵塞進程。比如下面這樣：

使用 queue.empty() 空為True

python哪個函數(shù)啟動進程和關(guān)閉進程

任何一種編程語言，啟動進程和關(guān)閉進程都是跟操作系統(tǒng)相關(guān)的操作，python中與操作系統(tǒng)打交道的話，推薦使用os模塊。

os.system() 函數(shù)可以啟動一個進程，執(zhí)行完之后返回狀態(tài)碼。

os.fork() 復制一個進程，如果是子進程返回0，如果是父進程返回子進程的pid，使用這個函數(shù)的時候，建議你學習一下linux編程的知識。

os.popen 以管道的方式創(chuàng)建進程。

os.spawnl 也可以創(chuàng)建進程，并能指定環(huán)境變量。

os.kill(pid, sig) 關(guān)閉一個進程，pid是進程號，sig是信號。與fork配合使用，例如你剛才用fork創(chuàng)建了一個子進程，它的pid是11990， 那么調(diào)用

os.kill( 11990, signal.CTRL_BREAK_EVENT)

就以ctrl+c的方式殺死了這個進程。

另外還有一個模塊multiprocessing，這個模塊封裝了很多創(chuàng)建進程和進程間通信的操作，可以讓你發(fā)揮多核的威力。

python中的進程-實戰(zhàn)部分

如果想了解進程 可以先看一下這一篇 python中的進程-理論部分

python中的多線程無法利用多核優(yōu)勢，如果想要充分地使用多核CPU的資源（os.cpu_count()查看），在python中大部分情況需要使用多進程。Python提供了multiprocessing。

multiprocessing模塊用來開啟子進程，并在子進程中執(zhí)行我們定制的任務（比如函數(shù)），該模塊與多線程模塊threading的編程接口類似。

　 multiprocessing模塊的功能眾多：支持子進程、通信和共享數(shù)據(jù)、執(zhí)行不同形式的同步，提供了Process、Queue、Pipe、Lock等組件。

需要再次強調(diào)的一點是：與線程不同，進程沒有任何共享狀態(tài)，進程修改的數(shù)據(jù)，改動僅限于該進程內(nèi)。

創(chuàng)建進程的類 ：

參數(shù)介紹：

group參數(shù)未使用，值始終為None

target表示調(diào)用對象，即子進程要執(zhí)行的任務

args表示調(diào)用對象的位置參數(shù)元組，args=(1,2,'tiga',)

kwargs表示調(diào)用對象的字典,kwargs={'name':'tiga','age':18}

name為子進程的名稱

方法介紹：

p.start()：啟動進程，并調(diào)用該子進程中的p.run()

p.run():進程啟動時運行的方法，正是它去調(diào)用target指定的函數(shù)，我們自定義類的類中一定要實現(xiàn)該方法

p.terminate():強制終止進程p，不會進行任何清理操作，如果p創(chuàng)建了子進程，該子進程就成了僵尸進程，使用該方法需要特別小心這種情況。如果p還保存了一個鎖那么也將不會被釋放，進而導致死鎖

p.is_alive():如果p仍然運行，返回True

p.join([timeout]):主線程等待p終止（強調(diào)：是主線程處于等的狀態(tài)，而p是處于運行的狀態(tài)）。timeout是可選的超時時間，需要強調(diào)的是，p.join只能join住start開啟的進程，而不能join住run開啟的進程

屬性介紹：

注意：在windows中Process()必須放到# if __name__ == '__main__':下

創(chuàng)建并開啟子進程的兩種方式

方法一:

方法二：

有了join，程序不就是串行了嗎？？？

terminate與is_alive

name與pid

本文名稱：python函數(shù)內(nèi)進程 python向進程發(fā)命令
文章分享：http://vcdvsql.cn/article20/hpgsco.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站策劃、營銷型網(wǎng)站建設、面包屑導航、響應式網(wǎng)站、云服務器、網(wǎng)站制作

廣告

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