尝试使用multiprocessing.Manager来管理您的队列,并使其他工作人员也可以访问它。
import multiprocessingdef worker(name, que): que.put("%d is done" % name)if __name__ == '__main__': pool = multiprocessing.Pool(processes=3) m = multiprocessing.Manager() q = m.Queue() workers = pool.apply_async(worker, (33, q))


