python中进程之间互相通信的用法介绍
June 15, 2015
本文主要介绍了python语言中不同进程之间通信的方法，并通过实际的例子来演示两个进程的互相通信：
本文实例讲述了Python进程间通信用法。分享给大家供大家参考。具体如下：
#!/usr/bin/env python |
# -*- coding=utf-8 -*- |
import multiprocessing |
def counsumer(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_q = multiprocessing.Process(target=counsumer,args=(q,)) |
cons_q.daemon = True |
cons_q.start() |
sequence = [1,2,3,4] |
producer(sequence,q) |
q.join() |
print 'success' |
希望本文所述对大家的Python程序设计有所帮助。
python中进程之间互相通信的用法介绍就是这样，欢迎大家参考。。。。
0 Comments