为什么我的 Python 多处理结果没有附加到回调上？

Question

我似乎无法弄清楚为什么我的结果在使用多处理包时没有附加。

我查看了许多类似的问题，但似乎无法弄清楚我做错了什么。这是我第一次尝试多处理（你可能会说）所以我不太了解文档中可能是问题的一部分的所有行话

在 PyCharm 中运行它会打印一个空列表，而不是所需的行总和列表。

import numpy as np
from multiprocessing import Pool
import timeit

data = np.random.randint(0, 100, size=(5, 1000))


def add_these(numbers_to_add):
    added = np.sum(numbers_to_add)
    return added


results = []
tic = timeit.default_timer()  # start timer

pool = Pool(3)
if __name__ == '__main__':
    for row in data:
        pool.apply_async(add_these, row, callback=results.append)


toc = timeit.default_timer()  # start timer
print(toc - tic)
print(results)  

编辑：关闭并加入池，然后在 if name==main 块中打印结果会导致重复引发以下错误，直到我手动停止执行：

运行时错误： 在当前进程完成其引导阶段之前，已尝试启动一个新进程。这可能意味着您没有使用 fork 来启动子进程，并且您忘记了在主模块中使用正确的习惯用法：

        if __name__ == '__main__':
            freeze_support()
            ...

如果程序不会被冻结以生成可执行文件，则可以省略“freeze_support()”行。

重现错误的代码：

import numpy as np
from multiprocessing import Pool, freeze_support
import timeit

data = np.random.randint(0, 100, size=(5, 1000))


def add_these(numbers_to_add):
    added = np.sum(numbers_to_add)
    return added


results = []
tic = timeit.default_timer()  # start timer

pool = Pool(3)
if __name__ == '__main__':
    for row in data:
        pool.apply_async(add_these, (row,), callback=results.append)
    pool.close()
    pool.join()
    print(results)


toc = timeit.default_timer()  # end timer
print(toc - tic)

Answer 1

我认为这样会更正确：

import numpy as np
from multiprocessing import Pool
import timeit

data = np.random.randint(0, 100, size=(5, 1000))


def add_these(numbers_to_add):
    added = np.sum(numbers_to_add)
    return added


results = []

if __name__ == '__main__':
    with Pool(processes=3) as pool:
        for row in data:
            results = pool.apply_async(add_these, (row,))
            try:
                print(results.get(timeout=1))
            except TimeoutError:
                print("Multiprocessing Timeout")