pythonCondition對象之生產(chǎn)者與消費者操作的代碼實例

import threading
import time
class Producer(threading.Thread):
 def init(self):
 threading.Thread.init(self)
 def run(self):
 global count
 while True:
 con.acquire()
 if count <20:
 count += 1
 print self.name," Producer product 1,current is %d" %(count)
 con.notify()
 else:
 print self.name,"Producer say box is full"
 con.wait()
 con.release()
 time.sleep(1)
class Consumer(threading.Thread):
 def init(self):
 threading.Thread.init(self)
 def run(self):
 global count
 while True:
 con.acquire()
 if count>4:
 count -=4
 print self.name,"Consumer consume 4,current is %d" %(count)
 con.notify()
 else:
 con.wait()
 print self.name," Consumer say box is empty"
 con.release()
 time.sleep(1)
count = 0
con = threading.Condition()
def test():
 for i in range(1):
 a = Consumer()
 a.start()
 for i in range(1):
 b =Producer()
 b.start()
if name=='main':
 test()