多线程下的奇怪问题，很奇怪，大家看看。

dzbjet

1. 
   
2. #!/usr/bin/env python
   
3. # -*- coding: gb2312 -*-
   
4. 
   
5. import threading
   
6. 
   
7. def flush_p(string):
   
8.     import sys
   
9.     print string
   
10.     sys.stdout.flush()
    
11. 
    
12. class mythread(threading.Thread):
    
13.     def __init__(self):
    
14.         threading.Thread.__init__(self, group=None)
    
15.         self.__cond = threading.Condition(threading.Lock())
    
16.         self.__task = None
    
17. 
    
18.     def run(self):
    
19.         while True:
    
20.             self.__cond.acquire()
    
21.             while self.__task == None:
    
22.                 self.__cond.wait()
    
23. 
    
24.             if isinstance(self.__task, exit_task):
    
25.                 self.__task = None
    
26.                 self.__cond.release()
    
27.                 flush_p('xxxxxxxxxxxxxxxxxxxx')
    
28.                 break
    
29.             try:
    
30.                 print 'b run'
    
31.                 self.__task.run()
    
32.                 print 'a run'               
    
33.             except:
    
34.                 pass
    
35.             finally:
    
36.                 flush_p('mythread: b none')
    
37.                 self.__task = None
    
38.                 flush_p('mythread: a none')
    
39.                 self.__cond.release()
    
40. 
    
41.     def set(self, task):
    
42.         self.__cond.acquire()
    
43.         self.__task = task
    
44.         self.__cond.notify()
    
45.         self.__cond.release()
    
46. 
    
47.     def terminate(self):
    
48.         flush_p('mythread: b terminate')
    
49.         self.set(exit_task())
    
50.         flush_p('mythread: a terminate')
    
51.         self.join()
    
52. 
    
53. class task:
    
54.     def __init__(self, callfunc=None, calldata=None):
    
55.         self.__callfunc = callfunc
    
56.         self.__calldata = calldata
    
57. 
    
58.     def run(self):
    
59.         if self.__callfunc != None:
    
60.             if self.__calldata != None:
    
61.                 self.__callfunc(self.__calldata)
    
62.             else:
    
63.                 self.__callfunc()
    
64.         else:
    
65.             pass
    
66. 
    
67. class exit_task(task):
    
68.     pass
    
69. 
    
70. class wrapper:
    
71.     def __init__(self):
    
72.         def worker():
    
73.             print 'worker'
    
74. 
    
75.         self.myt = mythread()
    
76.         self.myt.start()
    
77.         self.myt.set(task(worker))
    
78. 
    
79.     def __del__(self):
    
80.         self.myt.terminate()
    
81.         self.myt.join()
    
82. 
    
83.     def __Fuck(self):
    
84.         print 'fuck'
    
85. 
    
86. def main():
    
87.     w = wrapper()
    
88.    
    
89. 
    
90. if __name__ == '__main__':
    
91.     main()
    
92. 
    

复制代码

以上代码没有问题，但是如果把 self.myt.set(task(worker) 的worker换成类的成员函数(self.myt.set(task(self.__Fuck))    )，就会出现阻塞在self.__task = None 这块，一直不返回，
为什么？
即以下代码会阻塞：

1. 
   
2. #!/usr/bin/env python
   
3. # -*- coding: gb2312 -*-
   
4. 
   
5. import threading
   
6. 
   
7. def flush_p(string):
   
8.     import sys
   
9.     print string
   
10.     sys.stdout.flush()
    
11. 
    
12. class mythread(threading.Thread):
    
13.     def __init__(self):
    
14.         threading.Thread.__init__(self, group=None)
    
15.         self.__cond = threading.Condition(threading.Lock())
    
16.         self.__task = None
    
17. 
    
18.     def run(self):
    
19.         while True:
    
20.             self.__cond.acquire()
    
21.             while self.__task == None:
    
22.                 self.__cond.wait()
    
23. 
    
24.             if isinstance(self.__task, exit_task):
    
25.                 self.__task = None
    
26.                 self.__cond.release()
    
27.                 flush_p('xxxxxxxxxxxxxxxxxxxx')
    
28.                 break
    
29.             try:
    
30.                 print 'b run'
    
31.                 self.__task.run()
    
32.                 print 'a run'               
    
33.             except:
    
34.                 pass
    
35.             finally:
    
36.                 flush_p('mythread: b none')
    
37.                 self.__task = None
    
38.                 flush_p('mythread: a none')
    
39.                 self.__cond.release()
    
40. 
    
41.     def set(self, task):
    
42.         self.__cond.acquire()
    
43.         self.__task = task
    
44.         self.__cond.notify()
    
45.         self.__cond.release()
    
46. 
    
47.     def terminate(self):
    
48.         flush_p('mythread: b terminate')
    
49.         self.set(exit_task())
    
50.         flush_p('mythread: a terminate')
    
51.         self.join()
    
52. 
    
53. class task:
    
54.     def __init__(self, callfunc=None, calldata=None):
    
55.         self.__callfunc = callfunc
    
56.         self.__calldata = calldata
    
57. 
    
58.     def run(self):
    
59.         if self.__callfunc != None:
    
60.             if self.__calldata != None:
    
61.                 self.__callfunc(self.__calldata)
    
62.             else:
    
63.                 self.__callfunc()
    
64.         else:
    
65.             pass
    
66. 
    
67. class exit_task(task):
    
68.     pass
    
69. 
    
70. class wrapper:
    
71.     def __init__(self):
    
72.         def worker():
    
73.             print 'worker'
    
74. 
    
75.         self.myt = mythread()
    
76.         self.myt.start()
    
77.         self.myt.set(task(self.__Fuck))        
    
78. 
    
79.     def __del__(self):
    
80.         self.myt.terminate()
    
81.         self.myt.join()
    
82. 
    
83.     def __Fuck(self):
    
84.         print 'fuck'
    
85. 
    
86. def main():
    
87.     w = wrapper()
    
88.    
    
89. 
    
90. if __name__ == '__main__':
    
91.     main()
    

复制代码

dzbjet

另外，如果把

1. 
   
2.     def __del__(self):
   
3.         self.myt.terminate()
   
4.         self.myt.join()
   

复制代码

中的代码移到 __init__(self)中，则没有问题，以上两种情况（self.myt.set(task(worker)), self.myt.set(task(self.__Fuck))）都不会阻塞，这又是为什么呢？

dzbjet

可能是Python并没有自动调用__del__.

limodou

__del__的执行是不受你控制的。还是建议把__del__封装为其它的方法进行主动调用。

dzbjet

只好这样了

星尘细雨

看样子，你的第二种那个情况应该是主线程没有退出。

原因应该是在加锁上。__del__必然是会被调用的。
看看你这段代码：

1. 
   
2. finally:
   
3.                 flush_p('mythread: b none')
   
4.                 self.__task = None
   
5.                 flush_p('mythread: a none')
   
6.                 self.__cond.release()
   

复制代码

这里的 self.__task=None会造成wrapper对象的销毁，于是wrapper就会调用mythread的terminate，
而它里面还有一句 self.set(exit_task()) ， 这个也是需要加锁的！
python会在当前线程中来处理对象销毁而不管对象是在哪个线程中创建的！
这样，这个销毁warpper对象的动作因为mythread中的set需要获得锁，而锁是在
self.__task=None之后才能释放！

于是，，死锁了。。

[ 本帖最后由 星尘细雨 于 2007-7-3 17:50 编辑 ]

星尘细雨

尽量不要去重新定义__del__， 因为你很难控制它在什么时候调用，在程序中估计一个对象什么时候引用计数为0是一件很困难的事情。

dzbjet

原帖由 星尘细雨 于 2007-7-3 17:48 发表
看样子，你的第二种那个情况应该是主线程没有退出。

原因应该是在加锁上。__del__必然是会被调用的。
看看你这段代码：

finally:
                flush_p('mythread: b none')
                self. ...

是的，__del__必然是会调用的，但是为什么self.__task = None会使wrapper对象销毁呢？

星尘细雨

self.__task = None 会造成对self.__task的销毁，
因为self.__task里面引用了一个warpper的方法，
所以当销毁task的时候,warpper的引用计数也会减一的。
当引用计数值为0的时候对象就会被销毁。

通常很难计算对象在什么地方销毁的。

dzbjet

那么如果我把wrapper的__init__最后添加：
import time
time.sleep(0)
就没有问题，这又是为什么呢？

1.     def __init__(self):
   
2. 
   
3.         def worker():
   
4. 
   
5.             print 'worker'
   
6. 
   
7. 
   
8. 
   
9.         self.myt = mythread()
   
10. 
    
11.         self.myt.start()
    
12. 
    
13.         self.myt.set(task(self.__Fuck))
    
14. 
    
15.         import time
    
16. 
    
17.         time.sleep(0)

复制代码