Python 进程池Pool Queue,运行不出来结果!
文章目录
- 代码及结论
代码及结论
import os
from multiprocessing import Pool, Queue
from collections import Counterdef func(q):q.put(1)queue = Queue()with Pool(4) as pool:for i in range(10):pool.apply_async(func, args=(queue,),)print(queue.qsize())
上边的代码queue的size为0,为什么不是10?因为,Pool不支持这么用!您用错了。Process支持Queue,但是Pool并不支持!