编程论坛

 找回密码
 立即注册
广告联系qq1031180668广告位
查看: 106|回复: 0

[python] python Queue模块实现进程间通信

[复制链接]

963

主题

1684

帖子

3257

积分

管理员

Rank: 9Rank: 9Rank: 9

积分
3257

最佳新人活跃会员热心会员推广达人宣传达人灌水之王突出贡献优秀版主荣誉管理论坛元老

发表于 2018-5-29 16:57:01 | 显示全部楼层 |阅读模式
Queue本身是一个消息列队程序,可以通过这个模块来进行进程之间的相互通信

[Python] syntaxhighlighter_viewsource syntaxhighlighter_copycode
from multiprocessing import Process
from multiprocessing import Queue
import time

def write(q):
    while True:
        q.put("www.c0ks.com")
        time.sleep(1)
def read(q):
    while True:
        str=q.get()
        if(str!=""):
            print(str)

if __name__=="__main__":
    q=Queue()
    pw=Process(target=write,args=(q,))
    pr=Process(target=read,args=(q,))
    pw.start()
    pr.start()
    time.sleep(10)

    # 强制结束子进程
    pw.terminate()
    pr.terminate()






python Queue模块实现进程间通信

python Queue模块实现进程间通信


不积跬步,无以至千里
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

手机版|Archiver|小黑屋|sitemap|编程论坛 - 一个单纯的编程学习交流论坛 ( 豫ICP备15032706号 )

GMT+8, 2018-8-16 14:45 , Processed in 1.097841 second(s), 26 queries .

Powered by Discuz! X3.4

© 2001-2013 Comsenz Inc.

快速回复 返回顶部 返回列表