9.2.3 使用队列保持线程同步    作者:xieaotian发表于2009-06-05 16:53:36

	   

	   9.2.3 使用队列保持线程同步



# -*- coding:utf-8 -*-

# file: MP_MC.py

#

import threading

import time

import Queue

class Producer(threading.Thread):

   def __init__(self, threadname):

      threading.Thread.__init__(self, name = threadname)

   def run(self):

      global queue

      queue.put(self.getName())

      print ('%s put %s to queue' % (self.getName(), self.getName()))

class Consumer(threading.Thread):

   def __init__(self, threadname):

      threading.Thread.__init__(self, name = threadname)

   def run(self):

      global queue

      print ('%s get %s from queue' % (self.getName(), queue.get()))



queue = Queue.Queue()

plist = []

clist = []

for i in range(10):

   p = Producer('Producer' + str(i))

   c = Consumer('Consumer' + str(i))

   plist.append(p)

   clist.append(c)

#for i in range(10):

#   c = Consumer('Consumer' + str(i))

#   clist.append(c)



for i in plist:

   i.start()

   i.join()

for i in clist:

   i.start()

   i.join()

  

运行结果：



>>>

Producer0 put Producer0 to queue

Producer1 put Producer1 to queue

Producer2 put Producer2 to queue

Producer3 put Producer3 to queue

Producer4 put Producer4 to queue

Producer5 put Producer5 to queue

Producer6 put Producer6 to queue

Producer7 put Producer7 to queue

Producer8 put Producer8 to queue

Producer9 put Producer9 to queue

Consumer0 get Producer0 from queue

Consumer1 get Producer1 from queue

Consumer2 get Producer2 from queue

Consumer3 get Producer3 from queue

Consumer4 get Producer4 from queue

Consumer5 get Producer5 from queue

Consumer6 get Producer6 from queue

Consumer7 get Producer7 from queue

Consumer8 get Producer8 from queue

Consumer9 get Producer9 from queue