线程queue与进程queue

Posted 2021-01-04 justin-tim

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