python3中multiprocessing.Lock的共享判据

Question

有没有可能在python3中共享一个锁的判决书？我需要多个锁，因为我想保护共享资源的字典。每个资源都有一个锁：

manager = multiprocessing.Manager()

locks = manager.dict({key : manager.Lock() for key in range(100)})
shared_resource = manager.dict({key : SomeClass() for key in range(100)})

# later in a multi-processed function
def foo(key):
  # ...
  locks[key].acquire()
  shared_resource[key] = ...
  locks[key].release()
  # ...

这个玩具示例将失败，并显示以下错误：

multiprocessing.managers.RemoteError: 
---------------------------------------------------------------------------
Unserializable message: ('#RETURN', <unlocked _thread.lock object at 0x7f9a4c9dc468>)

你知道如何解决这个问题吗？我可以使用条件变量吗？或者，您如何保护资源列表？

Answer 1

好的，看起来这是ptyhon3.5的一个bug。

在python3.6中，它就像一个护身符。

Answer 2

我相信这是有可能的。当我运行这段代码时，我没有得到一个错误...我只是用'x‘替换了SomeClass。所以这里可能有个问题。此外，使用上下文管理器来获取和释放锁是一个很好的小抽象……

manager = multiprocessing.Manager()
locks = {key : manager.Lock() for key in range(100)}
shared_resource = {key : 'x' for key in range(100)}

# later in a multi-processed function
def foo(key):
   # ...
  with locks[key]:
  shared_resource[key] = 'xoyo'

if __name__ == '__main__':
    p = Process(target=foo, args=(1,))
    p.start()
    p = Process(target=foo, args=(1,))
    p.start()
    p = Process(target=foo, args=(1,))
    p.start()
    p.join()