在python中,任務(wù)并發(fā)一種方式是通過進程分支來實現(xiàn)的.在linux系統(tǒng)在,通過fork()方法來實現(xiàn)進程分支.
1.fork()調(diào)用后會創(chuàng)建一個新的子進程,這個子進程是原父進程的副本.子進程可以獨立父進程外運行.
2.fork()是一個很特殊的方法,一次調(diào)用,兩次返回.
3.fork()它會返回2個值,一個值為0,表示在子進程返回;另外一個值為非0,表示在父進程中返回子進程ID.
以下只能在linux中運行,不能在window下運行.
進程分支fork()
實例如下:
#!/usr/bin/python
#coding=utf-8
import os
def child():
??? print('hello from child', os.getpid())
??? os._exit(0)
def parent():
??? pid = os.fork()
??? if pid == 0:
??????? child()
??????? print 'fork child process error!'#如果打印該字符串,說明調(diào)用child()出錯
??? else:
??????? print('hello from parent', os.getpid(), pid)
parent()
運行結(jié)果如下:
('hello from parent', 29888, 29889)
('hello from child', 29889)
從結(jié)果不難看出, child()后的print字符并沒有打印處理,說明調(diào)用child()是沒有返回的.
fork和exec的組合
從上面的例子來看,調(diào)用child()方法后就直接退出了.但在實際的應(yīng)用中,我們希望分支出來的子進程能獨立運行另外一個新的程序.這時需要用到exec方法替換子進程,并且替換后進程的pid不會改變.exec方法不會返回.
首先解釋一下exec相關(guān)的8個方法組:
os.execv(program, cmdargs)
基本的”v”執(zhí)行形式,需要傳入可執(zhí)行的程序名,以及用來運行程序的命令行參數(shù)字符的列表或元組.
os.execl(program, cmdarg1, cmdarg2, …, cmdargN)
基本的”l”執(zhí)行形式,需要傳入可執(zhí)行的程序名,以及用來運行程序的命令行多個字符參數(shù).
os.execvp(program, args)
“p”模式下,基本的”v”執(zhí)行形式,需要傳入可執(zhí)行的程序名,以及用來運行程序的命令行參數(shù)字符的列表或元組.運行新程序的搜索路徑為當前文件的搜索路徑.
os.execlp(program, cmdarg1, cmdarg2, …, cmdargN)
“p”模式下,基本的”l”執(zhí)行形式,需要傳入可執(zhí)行的程序名,以及用來運行程序的命令行多個字符參數(shù).運行新程序的搜索路徑為當前文件的搜索路徑.
os.execve(program, args, env)
“e”模式下,基本的”v”執(zhí)行形式,需要傳入可執(zhí)行的程序名,以及用來運行程序的命令行參數(shù)字符的列表或元組.最后還要傳入運行新程序的需要的環(huán)境變量env字典參數(shù).
os.execle(program, cmdarg1, cmdarg2, …, cmdargN, env)
“e”模式下,基本的”l”執(zhí)行形式,需要傳入可執(zhí)行的程序名,以及用來運行程序的命令行多個字符參數(shù).最后還要傳入運行新程序的需要的環(huán)境變量env字典參數(shù).
os.execvpe(program, args, env)
在”p”和”e”的組合模式下,基本的”v”執(zhí)行形式,需要傳入可執(zhí)行的程序名,以及用來運行程序的命令行參數(shù)字符的列表或元組.最后還要傳入運行新程序的需要的環(huán)境變量env字典參數(shù).運行新程序的搜索路徑為當前文件的搜索路徑.
os.execlpe(program, cmdarg1, cmdarg2, …, cmdargN, env)
在”p”和”e”的組合模式下,基本的”l”執(zhí)行形式,需要傳入可執(zhí)行的程序名,以及用來運行程序的命令行多個字符參數(shù).最后還要傳入運行新程序的需要的環(huán)境變量env字典參數(shù).運行新程序的搜索路徑為當前文件的搜索路徑.
newprocess.py代碼如下:
#!/usr/bin/python
#coding=utf-8
import os
def child():
??? print('hello from child', os.getpid())
??? os._exit(0)
child()
主代碼如下:
#!/usr/bin/python
#coding=utf-8
import os
def child():
??? print('hello from child', os.getpid())
??? os._exit(0)
def parent():
??? pid = os.fork()
??? if pid == 0:
??????? os.execlp('python', 'python', 'newprocess.py')
??????? assert False, 'fork child process error!'
??? else:
??????? print('hello from parent', os.getpid(), pid)
parent()
輸出如下:
$ python TestFork.py
('hello from parent', 30791, 30792)
$ ('hello from child', 30792)
更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主
微信掃碼或搜索：z360901061
微信掃一掃加我為好友
QQ號聯(lián)系： 360901061
您的支持是博主寫作最大的動力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點擊下面給點支持吧，站長非常感激您！手機微信長按不能支付解決辦法：請將微信支付二維碼保存到相冊，切換到微信，然后點擊微信右上角掃一掃功能，選擇支付二維碼完成支付。
【本文對您有幫助就好】元
