python mulitprocessing 实例1
#!/usr/bin/env python#!coding=utf-8
import multiprocessing ,time
def consumer(input_q):
while True:
item = input_q.get()
#处理项目
print item
#发出信号，通知任务完成了
input_q.task_done()
def producer(sequence, output_q):
for item in sequence:
#将项目放入队列
output_q.put(item)
# 建立进程
if __name__ == "__main__":
q = multiprocessing.JoinableQueue()
#运行使用者进程
cons_p = multiprocessing.Process(target=consumer, args=(q,))
cons_p.daemon=True
cons_p.start()
cons_p2 = multiprocessing.Process(target=consumer, args=(q,))
cons_p2.daemon=True
cons_p2.start()
#生产项目，sequence 代表发送给使用者的项目序列
sequence =
producer(sequence,q)
#生产者使用此方法进行阻塞，直到队列中的所有项目均被处理。阻塞到将持续为队列中的
#每个项目均调用task_done()方法。
q.join()
time.sleep(5)
页:
[1]