Python Threadsafe Integer 使用锁减少答案

【问题标题】：Python Threadsafe Integer Decrease using locksPython Threadsafe Integer 使用锁减少
【发布时间】：2013-06-26 13:33:33
【问题描述】：

我有几个工作进程，它们应该在完成后减少一个共享整数。

为了确保线程安全，我尝试了一个锁，但不知何故它不起作用，在程序结束时打印出 worker 仍然会输出 4

我读过http://www.laurentluce.com/posts/python-threads-synchronization-locks-rlocks-semaphores-conditions-events-and-queues/

workers = 4
lock = threading.Lock()

def workerStopped(id,lock):
    lock.acquire()
    global workers
    print "Decrease workers (" + str(workers) + ")for #" + str(id)
    workers = workers - 1
    print "Now " + str(workers) + " Workers"
    lock.release()

class Worker(Process):
    def __init__(self, queue,ident,lock):
        super(Worker, self).__init__()

        self.queue= queue
        self.idstr= str(ident)
        self.lock = lock
        print "Ident" + self.idstr
  ......

workerStopped(self.idstr,self.lock)

 ....

for i in range(4):
    Worker( request_queue,i,lock ).start()

【问题讨论】：

请提供比“不知何故无法正常工作”更详细的描述。请注意，您的代码示例不是独立的，因此我们无法运行它并亲自查看问题所在。
见difference between thread and process，以及shared counter with python multiprocessing
workers 最后仍然是 4 ;) 在调用 worker 停止后它总是打印为 3

标签： python multithreading thread-safety locks

【解决方案1】：

感谢 mtadd，他提供了 http://eli.thegreenplace.net/2012/01/04/shared-counter-with-pythons-multiprocessing/ 的链接

似乎你必须以另一种方式在不同进程之间共享变量，而不是在线程之间共享

import time
from multiprocessing import Process, Value, Lock

def func(val, lock):
    for i in range(50):
        time.sleep(0.01)
        with lock:
            val.value += 1

if __name__ == '__main__':
    v = Value('i', 0)
    lock = Lock()
    procs = [Process(target=func, args=(v, lock)) for i in range(10)]

    for p in procs: p.start()
    for p in procs: p.join()

    print v.value

【讨论】：