python线程和进程的退出问题

howema

主进程创建一个子进程p，对一些数据进行处理，
然后再创建一个线程th，主要负责监控一个外部条件是否满足，如果条件满足，则通过terminate结束子进程p；
子进程p退出后，如何退出线程th？试了用join没有达到预期效果
这种处理方式有问题么？

代码逻辑如下：
###################
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进行比较, 了解python的GIL, 并且知道multiprocessing的实现原理, 怎么实现进程间共享互斥锁和条件变量, 怎么共享普通变量, 怎么使用互斥锁与条件变量保证事件不会丢失, 要求较高.

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()

复制代码

q1208c

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

sys.exit(0)