首页 > 编程语言 > 详细

线程queue与进程queue

时间:2018-09-07 12:29:29      阅读:164      评论:0      收藏:0      [点我收藏+]

进程queue:

from multiprocessing import Queue,Process
def func(qq):
qq.put(‘function:我要放数据,给你来取。。。‘)

if __name__ == ‘__main__‘:
q =Queue()
p =Process(target=func,args=(q,)) #需要把实例化q放到子进程,才能进行父进程与子进程之间队列交互
p.start()
print(q.get())
p.join()


线程queue
import threading
import queue

def func():
q.put(‘function:我要放数据,给你来取。。。‘)

if __name__ == ‘__main__‘:
q =queue.Queue() #全局变量声明 q,可以在子线程调用
t = threading.Thread(target=func,)
t.start()
print(q.get())
t.join()

线程queue与进程queue

原文:https://www.cnblogs.com/Justin-Tim/p/9603733.html

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