Установка

1

$ composer require symfony/semaphore

Использование

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

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

1
2
3
4
5
6
7
8

use Symfony\Component\Semaphore\SemaphoreFactory;
use Symfony\Component\Semaphore\Store\RedisStore;

$redis = new Redis();
$redis->connect('172.17.0.2');

$store = new RedisStore($redis);
$factory = new SemaphoreFactory($store);

Семфор создается путем вызова метода createSemaphore(). Его первый аргумент - произвольная строка, которая представляет блокированный ресурс. Его второй аргумент - макисмальное количество допустимых процессов. Затем, вызов к методу acquire() будет пробовать получить семафор:

1
2
3
4
5
6
7
8
9

// ...
$semaphore = $factory->createSemaphore('pdf-invoice-generation', 2);

if ($semaphore->acquire()) {
    // Ресурс "pdf-invoice-generation" заблокирован.
    // Здесь вы можете безопасно вычислисть и сгенерировать инвойс.

    $semaphore->release();
}

Если семафор не может быть получен, метод возвращает false. Метод acquire() может безопасно быть вызван множество раз, даже если семафор уже получен.