Python进程间通信Queue实例解析
|
本文研究的主要是Python进程间通信Queue的相关实例，具体如下。 1.Queue使用方法：
2.Queue使用实例： 来，上代码：
#!/usr/bin/env python3
import time
from multiprocessing import Process,Queue
q = Queue() #创建列队，不传数字表示列队不限数量
for i in range(11):
q.put(i)
def A():
while 1:
try:
num = q.get_nowait()
print('我是进程A,取出数字:%d'%num)
time.sleep(1)
except :
break
def B():
while 1:
try:
num = q.get_nowait()
print('我是进程B,取出数字:%d'%num)
time.sleep(1)
except :
break
p1 = Process(target = A)
p2 = Process(target = B)
p1.start()
p2.start()
此程序是在队列中加入10个数字，然后用2个进程来取出。 运行结果：
3.使用进程池Pool时，Queue会出错，需要使用Manager.Queue： 上代码
#!/usr/bin/env python3
import time
from multiprocessing import Pool,Manager,Queue
q = Manager().Queue()
for i in range(11):
q.put(i)
def A(i):
num = q.get_nowait()
print('我是进程%d,取出数字:%d'%(i,num))
time.sleep(1)
pool = Pool(3)
for i in range(10):
pool.apply_async(A,(i,))
pool.close()
pool.join()
运行结果：
当把Manager().Queue()直接换成Queue()，可能会出现资源混乱，缺少进程。 4.主进程定义了一个Queue类型的变量，并作为Process的args参数传给子进程processA和processB，两个进程一个向队列中写数据，一个读数据。
import time
from multiprocessing import Process,Queue
MSG_QUEUE = Queue(5)
def startA(msgQueue):
while True:
if msgQueue.empty() > 0:
print 'queue is empty %d' % (msgQueue.qsize())
else:
msg = msgQueue.get()
print 'get msg %s' % (msg,)
time.sleep(1)
def startB(msgQueue):
while True:
msgQueue.put('hello world')
print 'put hello world queue size is %d' % (msgQueue.qsize(),)
time.sleep(3)
if __name__ == '__main__':
processA = Process(target=startA,args=(MSG_QUEUE,))
processB = Process(target=startB,))
processA.start()
print 'processA start..'
processB.start()
print 'processB start..'
其打印的结果如下：
总结 以上就是本文关于Python进程间通信Queue实例解析的全部内容，希望对大家有所帮助。感兴趣的朋友可以继续参阅本站其他相关专题，如有不足之处，欢迎留言指出。感谢朋友们对本站的支持！ 您可能感兴趣的文章:
（编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |