生产者消费者小demo

import queue
import threading
import time

class product(threading.Thread):
 def __init__(self,Thread_id):
     super(product, self).__init__()
     self.Thread_id=Thread_id

 def run(self):
     while 1:
         global  q
         temp=q.get()
         print (self.Thread_id,'get a')
         time.sleep(1)

class consume(threading.Thread):
 def __init__(self,Thread_id):
     super(consume, self).__init__()
     self.Thread_id = Thread_id

 def run(self):
     while 1:
         global q
         q.put('a')
         print (self.Thread_id,'put a')
         time.sleep(1.5)

if __name__=='__main__':
 num=3
 t=[]
 t1=[]
 q=queue.Queue()
 a=product(1)
 b=consume(1)
 a.start()
 b.start()