python - python中的共享内存并行处理

Question

我有一个字符串列表，我想将这些列表元素放入适当的存储桶中。

def bucketElements(i):
    global buckA, buckB, buckC
    if i.startswith('A'):
        buckA.add(i)
    elif i.startswith('B'):
        buckB.add(i)
    elif i.startswith('C'):
        buckC.add(i)

现在我想为列表中的每个元素并行调用此方法。像这样的事情，

buckA,buckB, buckC = set(), set(), set()
pool = multiprocessing.Pool(processes=10)
pool.map(bucketElements, buckList)

由于我正在更新函数内的全局变量，因此我无法使用多重处理。无论如何我可以改进我的处理吗？目前我这样调用它，

buckA,buckB, buckC = set(), set(), set()
for i in buckList:
    bucketElements(i)

Answer 1

您有 3 个选择:

• 队列()
• Manager.Value()
• Manager.list()

Python » 文档:multiprocessing.html#managers