下面就是今天下午的研究成果。
發(fā)布系統(tǒng)需要響應(yīng)用戶的中斷請(qǐng)求,需要在GET方法中殺掉由subprocess派生的子進(jìn)程,剛開始直接用os.kill 發(fā)現(xiàn)子進(jìn)程的子進(jìn)程無法kill,谷歌了一些,發(fā)現(xiàn)kill可以干掉進(jìn)程組,于是測(cè)試,但是默認(rèn)情況下,subprocess派生的進(jìn)程組和主程序,也就是我的web.py進(jìn)程是在一個(gè)進(jìn)程組里的,這要是kill了,那就調(diào)的了。
繼續(xù)翻google,看subprocess的document時(shí)發(fā)現(xiàn)這個(gè)變量:
subprocess.CREATE_NEW_PROCESS_GROUPA Popen creationflags parameter to specify that a new process group will be created. This flag is necessary for using os.kill() on the subprocess.
This flag is ignored if CREATE_NEW_CONSOLE is specified.
比較高興,以為能解決問題了,結(jié)果測(cè)試半天,才了解這玩意是only windows的,我去啊,不過想到了,win能做到的,linux肯定也可以,于是定位到
preexec_fn
又是一通google,不是對(duì)象嗎,弄了個(gè)setpgid(0,0) 測(cè)試了,子進(jìn)程還是和主調(diào)進(jìn)程屬于同一個(gè)進(jìn)程組,后來靈機(jī)一動(dòng):
preexec_fn = os.setpgrp
這樣竟然解決了新生成進(jìn)程組的問題。
繼續(xù)努力,后面遇到的就是僵死進(jìn)程的問題了,os.waitpid了一下就解決了。
剛開始waitpid的時(shí)候,還在linxu上man了半天,看著linxu手冊(cè)里的參數(shù),還是不放心啊,結(jié)果python里的os.waitpid竟然沒有那么多參數(shù),而且沒有返回值,簡(jiǎn)陋啊。不過正解決了我的問題。
下面是今天的完全測(cè)試代碼
[liufeng@1.2.3.4 kill-subprocess]$ cat sub-process.py import subprocessimport osimport timedef my_func():#派生兩個(gè)子進(jìn)程,子進(jìn)程里又派生幾個(gè)sleep的孫子進(jìn)程,主要是為了測(cè)試kill進(jìn)程組。run_str2 = '/bin/sh test.sh'run_str = '/bin/sh test_quick.sh'cmd2 = run_str.split()cmd = run_str.split()#測(cè)試了一些個(gè)preexec_fn的值,最終發(fā)現(xiàn)能用的,對(duì)python的對(duì)象的概念還是不理解啊,新手,新手。#p = subprocess.Popen(cmd, stdin = subprocess.PIPE, stdout = subprocess.PIPE, stderr = subprocess.PIPE, shell = False, creationflags = subprocess.CREATE_NEW_PROCESS_GROUP)#p = subprocess.Popen(cmd, stdin = subprocess.PIPE, stdout = subprocess.PIPE, stderr = subprocess.PIPE, shell = False, creationflags = 0)p = subprocess.Popen(cmd, stdin = subprocess.PIPE, stdout = subprocess.PIPE, stderr = subprocess.PIPE, shell = False, preexec_fn = os.setpgrp )p2 = subprocess.Popen(cmd2, stdin = subprocess.PIPE, stdout = subprocess.PIPE, stderr = subprocess.PIPE, shell = False, preexec_fn = os.setpgrp )#@p = subprocess.Popen(cmd, stdin = subprocess.PIPE, stdout = subprocess.PIPE, stderr = subprocess.PIPE, shell = False, preexec_fn = os.setpgid(0, 0) )pid = p.pidpgid = os.getpgid(pid)print "pid: %d/n" %pidprint "pgid: %d/n" %pgidreturn pidpid = my_func()#p.wait()print "now , sleep 2s ,then , os.kill gpid %d" % pidtime.sleep(20)a = os.kill(-pid, 9)print "kill,return:"print a# kill的時(shí)候,我測(cè)試了kill 沒有權(quán)限的root進(jìn)程,會(huì)報(bào)錯(cuò):權(quán)限不允許# 測(cè)試了kill p p2 都可以kill#a = os.kill(2445, 9)#print "kill root process 2445 ,return:"#print a#p.wait()#os.waitpid(pgid, 0)# 2445 is a root process#os.waitpid(2445, 0)#os.waitpid(p2.pid, 0)os.waitpid(pid, 0)print "waitpid,return:"print atime.sleep(22)print "done..."#p.terminate()#p.kill()#p.wait()##time.sleep(40)#os.kill(pid, 9)
新聞熱點(diǎn)
疑難解答
圖片精選