首页 > 系统服务 > 详细

通过Queue方法实现进程间通信

时间:2017-12-14 20:18:01      阅读:217      评论:0      收藏:0      [点我收藏+]
from multiprocessing import Process,Queue
import time
def write(q):
    for i in range(1000000000):
        q.put(i)
        # time.sleep(1)
        print(q)


def read(q):
    while True:

            i=q.get()
            print(i,read)


if __name__ == __main__:
    q=Queue(10000)
    wp=Process(target=write,args=(q,))
    rp=Process(target=read,args=(q,))
    wp.start()

    rp.start()
    rp.join()

 

通过Queue方法实现进程间通信

原文:http://www.cnblogs.com/ldq1996/p/8039427.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!