找回密码
 立即注册

QQ登录

只需一步,快速开始

扫一扫,访问微社区

查看: 1831|回复: 1

time.sleep(random.random()) #z为啥这句不写,read方法就读不出...

1

主题

1

帖子

1

积分

贫民

积分
1
sophie1314179 发表于 2017-6-29 17:38:14 | 显示全部楼层 |阅读模式
from multiprocessing import Process, Queueimport os, time, random# 写数据进程执行的代码:def write(q):    for value in ['A', 'B', 'C']:        print 'Put %s to queue...' % value        q.put(value)          time.sleep(random.random())    #z为啥这句不写,read方法就读不出来?# 读数据进程执行的代码:def read(q):    while True:        value = q.get(True)        print 'Get %s from queue.' % valueif __name__=='__main__':    # 父进程创建Queue,并传给各个子进程:    q = Queue()    pw = Process(target=write, args=(q,))    pr = Process(target=read, args=(q,))    # 启动子进程pw,写入:    pw.start()    # 启动子进程pr,读取:    pr.start()    # 等待pw结束:    pw.join()    # pr进程里是死循环,无法等待其结束,只能强行终止:    pr.terminate()
回复

使用道具 举报

3

主题

208

帖子

208

积分

侠客

积分
208

热心会员

uitb 发表于 2017-6-29 18:17:32 | 显示全部楼层
好乱,搞成代码的格式开看一点吧
回复 支持 反对

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

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