Python:线程，队列运用

thread_Queue.py

#coding=utf-8
import threading, Queue
import time, random
"""
线程，队列同步运用
"""
##############
# Producer thread
##############
class Producer(threading.Thread):
	def __init__(self, threadname, queue):
		threading.Thread.__init__(self, name = threadname)
		self.sharedata = queue
	def run(self):
		for i in range(20):
			print(self.getName(),'adding',i,'to queue')
			self.sharedata.put(i)
			time.sleep(random.randrange(10)/10.0)
			print(self.getName(),'Finished')

###############
# Consumer thread
###############
class Consumer(threading.Thread):
	def __init__(self, threadname, queue):
		threading.Thread.__init__(self, name = threadname)
		self.sharedata = queue
	def run(self):
		for i in range(20):
			print(self.getName(),'got a value:',self.sharedata.get())
			time.sleep(random.randrange(10)/10.0)
			print(self.getName(),'Finished')

############
# Main thread
############
def main():
	queue = Queue.Queue()
	producer = Producer('Producer', queue)
	consumer = Consumer('Consumer', queue)

	print ('Starting threads ...')
	producer.start()
	consumer.start()

	producer.join()
	consumer.join()

	print ('All threads have terminated.')

#################################################
#测试代码
if __name__ == '__main__':
	main()