python線程和進(jìn)程的退出問題

howema

主進(jìn)程創(chuàng)建一個子進(jìn)程p，對一些數(shù)據(jù)進(jìn)行處理，
然后再創(chuàng)建一個線程th，主要負(fù)責(zé)監(jiān)控一個外部條件是否滿足，如果條件滿足，則通過terminate結(jié)束子進(jìn)程p；
子進(jìn)程p退出后，如何退出線程th？試了用join沒有達(dá)到預(yù)期效果
這種處理方式有問題么？

代碼邏輯如下：
###################
global_p = 0

test():
......
while True:
if(condition == True):
global_p.terminate()
......

if __name__ == "__main__":
......
while True:
   ......        
th = threading.Thread(target = test,args=())
th.start()
p = multiprocessing.Process(target = s_process, args=(,))
p.start()
global_p = p               
p.join()   

linux_c_py_php

這得用條件變量+互斥鎖才能完成.

你需要對multiprocessing存在的理由與threading進(jìn)行比較, 了解python的GIL, 并且知道m(xù)ultiprocessing的實(shí)現(xiàn)原理, 怎么實(shí)現(xiàn)進(jìn)程間共享互斥鎖和條件變量, 怎么共享普通變量, 怎么使用互斥鎖與條件變量保證事件不會丟失, 要求較高.

1. [root@vps616 python]# cat main.py
   
2. #python2.7.3
   
3. #coding=utf-8
   
4. 
   
5. from multiprocessing import Process, Lock, Condition, Value
   
6. 
   
7. def callback(mutex, cond, val):
   
8.     mutex.acquire()
   
9.     while not val.value:
   
10.         cond.wait()
    
11.     print "sub proc done, exit..."
    
12.     mutex.release()
    
13. 
    
14. if __name__ == "__main__":
    
15.     mutex = Lock()
    
16.     cond = Condition(mutex)
    
17.     val = Value('i', 0)
    
18.     proc = Process(target = callback, args = (mutex, cond, val))
    
19.     proc.start()
    
20.     mutex.acquire()
    
21.     val.value = 1
    
22.     cond.notify()
    
23.     mutex.release()
    
24.     proc.join()

復(fù)制代碼

q1208c

在這行后面加一行 global_p.terminate()

sys.exit(0)