如何在Python中让多进程函数返回和存储值？

Question

我有一个函数，我将运行多处理。然而，函数返回一个值，我不知道如何存储该值一旦完成

我在网上的某个地方读到过关于使用队列的文章，但我不知道如何实现它，也不知道这是否可行

cores = []
for i in range(os.cpu_count()):
    cores.append(Process(target=processImages, args=(dataSets[i],))) 
for core in cores: 
    core.start()
for core in cores:
    core.join()

其中函数“processImages”返回一个值。如何保存返回值

Answer 1

不能从另一个进程返回变量。建议的方法是创建一个Queue（multiprocessing.Queue），然后让您的子进程将结果放入该队列，一旦完成，您可以将它们读回，如果您有很多结果，这种方法很有效

如果您只需要一个数字，那么使用Value或Array可能会更简单

请记住，您不能使用简单的变量，它必须用multiprocessinglib中的上述类进行包装