多线程讲生产者与消费者

    生产者与消费者问题是典型的同步问题。这里简单介绍两种不同的实现方法。
 
1，  条件变量
 



[python] view plaincopy
01.import threading  
02.  
03.import time  
04.  
05.class Producer(threading.Thread):  
06.  
07.    def __init__(self, t_name):  
08.  
09.        threading.Thread.__init__(self, name=t_name)  
10.  
11.   
12.  
13.    def run(self):  
14.  
15.        global x  
16.  
17.        con.acquire()  
18.  
19.        if x > 0:  
20.  
21.            con.wait()  
22.  

23.        else:  
24.  
25.            for i in range(5):  
26.  
27.                x=x+1  
28.  
29.                print "producing..." + str(x)  
30.  
31.            con.notify()  
32.  
33.        print x  
34.  
35.        con.release()  
36.  
37.   
38.  
39.class Consumer(threading.Thread):  
40.  
41.    def __init__(self, t_name):  
42.  
43.        threading.Thread.__init__(self, name=t_name)  
44.  
45.    def run(self):  
46.  
47.        global x  
48.  
49.        con.acquire()  
50.  
51.        if x == 0:  
52.