码迷,mamicode.com
首页 > 编程语言 > 详细

线程queue与进程queue

时间:2018-09-07 13:59:51      阅读:114      评论:0      收藏:0      [点我收藏+]

标签:from   tar   变量声明   join()   __name__   tip   UNC   join   target   

进程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

标签:from   tar   变量声明   join()   __name__   tip   UNC   join   target   

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

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!