python - 我可以在多处理池星图方法中传递队列对象吗

Question

<分区>

Answer 1

尝试使用 Manager()像这样:

from multiprocessing import Manager, Pool


def get_data(pageNo, q):
    q.put(pageNo * pageNo)


if __name__ == "__main__":
    m = Manager()
    q = m.Queue()
    p = {}
    no_pages = 5
    pool_tuple = [(x, q) for x in range(1, no_pages)]
    with Pool(processes=3) as pool:
        pool.starmap(get_data, pool_tuple)
    for i in range(1, no_pages):
        print("result", i, ":", q.get())

输出:

result 1 : 1
result 2 : 4
result 3 : 9
result 4 : 16