Open Source Ecosystems

This library provides a Redis mutex implementation for yiisoft/mutex.

Requirements

PHP 7.4 or higher.

Installation

The package could be installed with Composer:

composer require yiisoft/mutex-redis

General usage

The package provides two classes implementing MutexInterface and MutexFactoryInterface from the yiisoft/mutex package:

/**
 * @var \Predis\ClientInterface $client Predis client instance to use.
 */

$mutex = new \Yiisoft\Mutex\Redis\RedisMutex(
    'mutex-name',
    $client,
    60, // Optional. Number of seconds in which the lock will be auto released. Default is `30`.
);

$mutexFactory = new \Yiisoft\Mutex\Redis\RedisMutexFactory(
    $client,
    60, // Optional. Number of seconds in which the lock will be auto released. Default is `30`.
);

For more information about the client instance and connection configuration, see the documentation of the predis/predis package.

There are multiple ways you can use the package. You can execute a callback in a synchronized mode i.e. only a single instance of the callback is executed at the same time:

$synchronizer = new \Yiisoft\Mutex\Synchronizer($mutexFactory);

$newCount = $synchronizer->execute('critical', function () {
    return $counter->increase();
}, 10);

Another way is to manually open and close mutex:

$simpleMutex = \Yiisoft\Mutex\SimpleMutex($mutexFactory);

if (!$simpleMutex->acquire('critical', 10)) {
    throw new \Yiisoft\Mutex\Exception\MutexLockedException('Unable to acquire the "critical" mutex.');
}

$newCount = $counter->increase();
$simpleMutex->release('critical');

It could be done on lower level:

$mutex = $mutexFactory->createAndAcquire('critical', 10);
$newCount = $counter->increase();
$mutex->release();

And if you want even more control, you can acquire mutex manually:

$mutex = $mutexFactory->create('critical');

if (!$mutex->acquire(10)) {
    throw new \Yiisoft\Mutex\Exception\MutexLockedException('Unable to acquire the "critical" mutex.');
}

$newCount = $counter->increase();
$mutex->release();

The RedisMutex supports the "wait for a lock for a certain time" functionality. Using the withRetryDelay() method, you can override the number of milliseconds between each try until specified timeout times out: