1、背景 2、解决办法
1、背景使用multiprocessing.Process启动新进程,使用multiprocessing.Queue()消息队列为进程间通讯,没有问题。
但是最近业务中使用了进程池,发现在进程池中无法使用multiprocessing.Queue()通讯。
示例如下:
# coding=utf-8
# Test_process.py 进程池无法使用multiprocessing.Queue()队列的问题
from concurrent.futures import ProcessPoolExecutor
import multiprocessing
def task(arg):



