Python中的多处理队列

Python中的多处理队列

尝试这个：

import multiprocessingnum_procs = 4def do_work(message):  print "work",message ,"completed"def worker():  for item in iter( q.get, None ):    do_work(item)    q.task_done()  q.task_done()q = multiprocessing.JoinableQueue()procs = []for i in range(num_procs):  procs.append( multiprocessing.Process(target=worker) )  procs[-1].daemon = True  procs[-1].start()source = ['hi','there','how','are','you','doing']for item in source:  q.put(item)q.join()for p in procs:  q.put( None )q.join()for p in procs:  p.join()print "Finished everything...."print "num active children:", multiprocessing.active_children()