求助多线程问题

rockyaow

代码如下

1. import threading
   
2. import time
   
3. import Queue
   
4. 
   
5. Q = Queue.Queue()
   
6. 
   
7. Q_process = Queue.Queue()
   
8. 
   
9. lock = threading.Lock()
   
10. lock2 = threading.Lock()
    
11. 
    
12. def do(Q, Q_process, i):
    
13.     #log = build_logger('down %s'%i)
    
14.     # threading loop
    
15.     print 'thread %s start'%(i)
    
16.     while True:
    
17.         if Q.empty():
    
18.             print('thread %s Queue is empty will be quit'%(i))
    
19.             break
    
20.         print 'wait lock %s'%(i)
    
21.         if lock.acquire(1):
    
22.             print 'lock in %s'%(i)
    
23.             num = Q.get()
    
24.             lock.release()
    
25.             print 'release lock %s'%(i)
    
26.         num = num * 100
    
27.         print 'wait lock2 %s'%(i)
    
28.         if lock2.acquire(1):
    
29.             print 'lock2 in %s'%(i)
    
30.             Q_process.put(num)
    
31.             lock2.release()
    
32.             print 'release lock2 %s'%(i)
    
33. 
    
34. 
    
35. 
    
36. 
    
37. for x in range(5000):
    
38.     Q.put(x)
    
39. 
    
40. tlist = []
    
41. for i in range(100):
    
42.     t = threading.Thread(target = do, args = (Q, Q_process, i))
    
43.     tlist.append([t,i])
    
44.     t.start()
    
45. 
    
46. 
    
47. for x in tlist:
    
48.    t, i = x
    
49.    print 'waiting %s'%(i)
    
50.    t.join()
    
51.    print '%s over'%(i)
    
52. 
    
53. print '! ' * 100
    
54. 
    
55. while True:
    
56.     if Q_process.empty():
    
57.         print 'empty'
    
58.         break
    
59.     num = Q_process.get()
    
60.     print num
    

复制代码

100%跑死，是哪里问题？

106033177

回复 1# rockyaow
第一子线程会全部阻塞在 Q.get() 第二不需要锁.

   

jxing_ing

你先判断 Q.empty()， 然后加锁， 再Q.get()。 在你判断非空与加锁之间其他线程可能get()了队列的数据, 导致当前进程 Q.get() 阻塞。
应该把锁加到 Q.empyt() 之前( Q.empty(): break 的时候记得 release() )。