Python递增函数中用多处理.pool.map()

Question

我试图在函数中按顺序递增多处理.pool.map(). 当我运行下面的代码时，我得到的数字递增的次数与每个数字的are池相同。在

import time
import multiprocessing
import decimal
import random

lists = ['a', 'b', 'c', 'd', 'e', 'f', 'g', 'h','i', 'j', 'k']
def thefunction(listi):
    global number
    number += 1
    time.sleep(decimal.Decimal(random.random()))
    print time.strftime('%H:%M:%S'), number, listi

number = 0
pool = multiprocessing.Pool(4)
pool.map(thefunction, lists)
print number

结果是这样打印出来的

^{pr2}$

我怎样才能正确地增加数字？在

在(时间。睡觉(十进制。十进制(随机。随机（）））仅用于停止脚本打印到同一行）

Answer 1

您可能需要一个^{}作为共享状态。在

或者更确切地说，这将满足您的要求，但它可能不是您真正想要的；并行上下文中的共享状态通常是设计缺陷的标志。相反，您可以做的一件事是让每个进程跟踪它已处理的项目数，并将计数返回给父进程；然后父进程可以合计每个进程完成的作业数，以排序到目前为止已完成的工作量。在

您尝试跨越流程边界进行计数的原因是什么？在

Answer 2

这个例子不起作用的原因是计数器的几个实例是分别创建和递增的。在

您需要为每个启动的进程创建一个共享计数器和锁，并对其进行适当初始化：

import time
from multiprocessing import Pool, Value, Lock
import decimal
import random

number = Value('i', 0)
lock = Lock()
lists = ['a', 'b', 'c', 'd', 'e', 'f', 'g', 'h','i', 'j', 'k']

def thefunction(listi):
    time.sleep(decimal.Decimal(random.random()))
    with lock:
        number.value += 1
        print time.strftime('%H:%M:%S'), number.value, listi

def initializer(*args):
    global number, lock
    number, lock = args

pool = Pool(4, initializer, (number, lock))
pool.map(thefunction, lists)
print number.value