Python 2.7 多处理障碍

Question

我正在使用 Python 2.7，并且一直在将多线程代码转换为多处理代码以避免 GIL 锁定问题。但是，我在多处理模块中没有看到屏障实现（知道如何实现吗？）。

我看到了这个问题： Is it possible to use multiprocessing.Event to implement a synchronization barrier for pool of processes? 但我不确定它是否会正常工作，因为它不使用任何锁！

谢谢！

Answer 1

我很确定 multiprocessing 包的内置同步原语提供了您所需要的：https://docs.python.org/2/library/multiprocessing.html#synchronization-primitives

Answer 2

这里是多处理的类比，至于从这里开始的线程:

from multiprocessing import Process, Semaphore, Value

class Barrier:
    def __init__(self, n):
        self.n       = n
        self.count   = Value('i', 0)
        self.mutex   = Semaphore(1)
        self.barrier = Semaphore(0)

    def wait(self):
        self.mutex.acquire()
        self.count.value += 1
        self.mutex.release()

        if self.count.value == self.n:
            self.barrier.release()

        self.barrier.acquire()
        self.barrier.release()

然后是主线程中的用法示例：

barrier = Barrier(2)
process = Process(target = my_second_thread, args = (barrier,))
process.start()

Python 2.7 多处理障碍

Python 2.7 Multiprocessing Barrier

python

multiprocessing

barrier

python-2.7