Proceess,Pool中的Queue通讯以及Thread中的Queue

xiaoxiao2021-02-28  127

自己的描述,不对之处,欢迎拍砖~~

三个Queue的都是用于多任务的通讯功能,用法基本都一样: q.put(obj) q.get(obj)

multiprocessing.Queue() 用于普通的进程间通讯–》multiprocessing.Process

q = Queue() p = Process(target=process_test, args=(q,)) q.put(0)

multiprocessing.Manage.Queue()用于进程池间进程的通讯–》multiprocessing.Pool

q = Manager().Queue() q.put(1) po = Pool() po.apply(process_test, args=(q,))

Thread中的Queue–》【待续】

转载请注明原文地址: https://www.6miu.com/read-38644.html

最新回复(0)