Синхронизация процесса в Python

Question

Я пытаюсь синхронизировать несколько процессов с помощью семафоров. Я думал, что вместо того, чтобы создать функцию для каждого процесса, можно было бы в более общем виде, с одной функцией и некоторыми аргументами для зависимостей:

import multiprocessing 
from multiprocessing import * 

class Worker: 
    def __init__(self, size): 
     self._semaphores = [Semaphore(0)]*(size + 1) 

    def run(self, name, acquire, release): 
     for i in acquire: 
      self._semaphores[i].acquire() 

      print('Running', name) 

     for i in release: 
      self._semaphores[i].release() 

В этом случае я получил пять процессов. Первый начинается первым, вторым и третьим после первого, четвертым после второго и третьего, а пятым после четвертого.

if __name__ == '__main__': 
    worker = Worker(5) 
    Process(target=worker.run, args=('5', [5], [])).start() 
    Process(target=worker.run, args=('4', [4,4], [5])).start() 
    Process(target=worker.run, args=('3', [3], [4])).start() 
    Process(target=worker.run, args=('2', [2], [4])).start() 
    Process(target=worker.run, args=('1', [], [2,3])).start() 

Ожидаемый результат будет:

Running 1 
Running 2 
Running 3 
Running 4 
Running 5 

Но синхронизация не работает, как ожидалось. Выполнение является случайным, включая взаимоблокировки. Почему это?

Answer 1

[Semaphore(0)]*(size + 1) создает список с size + 1 ссылками на одногоSemaphore объекта. Вы должны сделать различные экземпляры этого класса:

self._semaphores = [Semaphore(0) for _ in range(size + 1)] 

Answer 2

Отступ отпечатке неверен, который предотвращает («Бег», «1»). После этого фиксируется 1 печать, за которой следуют 2 и 3, а затем 4, затем 5. 2 и 3 смешиваются, потому что они начинаются вместе, поэтому работа выполняется так, как ожидалось.