关于from multiprocessing import Queue

来源:11-11 进程间通信 - Queue、Pipe,Manager

村口胡大爷

2021-07-06

多进程里面的这个 Queue 不能用于进程池间的通信。

进程池有两种模式,一个是 multiprocessing 里面的,一个是 concurrent.futures 里面的
1.pool = multiprocessing.Pool(2))
2.process_pool = ProcessPoolExecutor(2)

请问这个 Queue 是不能用于第一种模式,还是两种都不行?因为课程里面的例子只讲到第一种不行。

写回答

1回答

bobby

2021-07-07

concurrent.futures 是基于threading和multiprocessing的进一步封装,用起来简单,

from multiprocessing import Queue

这里的queue是用于多进程的,所以要看你的ProcessPoolExecutor是基于进程的还是线程的

0
5
Necromancer_
回复
村口胡大爷
我认为对,进程池就用manager里面的数据结构
2021-12-31
共5条回复

Python3高级核心技术97讲,高级进阶的必学课程

socket编程/多线程/多进程/线程池/asyncio并发编程/协程和异步IO

2121 学习 · 551 问题

查看课程