Python多进程管理器类对象线程/进程安全

Question

我有一个类，在多个消费者之间共享（使用生产者/消费者方法）。我的问题涉及对该类调用的方法。我需要实现锁定还是管理器类是线程安全的？

import multiprocessing as mp
from multiprocessing.manager import BaseManager

class SampleClass(object):

    def __init__(self):
        self._count = 0

    # Does locking need to be implemented here?
    def increment(self):
        self._count += 1

BaseManager.register('SampleClass', SampleClass)
manager = BaseManager()
manager.start()

instance = manager.SampleClass()

jobs = []
for i in range(0, 5):
    p = mp.Process(target=some_func, args=(instance,))
    jobs.append(p)
    p.start()

for p in jobs:
    p.join()

- Aaron Phalen

Answer 1

我认为是这样的。正如在另一个问题的评论中所说：

1. multiprocessing: 如何在多个进程之间共享字典？

manager.dict() 是进程安全的吗？

@LorenzoBelli，如果你问的是访问管理器是否同步，我相信答案是肯定的。multiprocessing.Manager() 返回一个SyncManager实例，其名称表明了这一点！

- user