read()进程不是应该持续while循环,不停的输出吗?为什么write进程put 一次,read 进程才执行一次?
Topic sourceQueue.put(item,block = True,timeout = None )¶
将项目放入队列。如果可选的args 块为true且timeout为 None(默认值),则在必要时阻塞,直到有空闲插槽可用。如果 timeout是一个正数,则它会阻止最多超时秒,Full如果在该时间内没有可用的空闲槽,则会引发异常。否则(块为假),如果空闲插槽立即可用,则将项目放在队列上,否则引发Full异常(在这种情况下忽略超时)
- 1
lemon9527
from multiprocessing import Process, Queue import os, time, random
写数据进程执行的代码:
def write(q): print('Process to write: %s' % os.getpid()) for value in ['A', 'B', 'C']: print('Put %s to queue...' % value) q.put(value) time.sleep(random.random())
读数据进程执行的代码:
def read(q): print('Process to read: %s' % os.getpid()) while True: value = q.get(True) print('Get %s from queue.' % value)
if name=='main':
都数据进程的代码start 之后,里面的while 循环不是应该一直在输出吗?为什么write进程put一次,read进程才会print一次。