yiisoft/mutex-pdo-pgsql

Yii Mutex 库 - PostgreSQL PDO 驱动

1.1.0 2021-10-19 07:18 UTC

README

Yii

Yii Mutex 库 - PostgreSQL PDO 驱动


Latest Stable Version Total Downloads Build status Scrutinizer Code Quality Code Coverage Mutation testing badge static analysis type-coverage

此库为 yiisoft/mutex 提供了 PostgreSQL 锁的实现。

需求

  • PHP 7.4 或更高版本。
  • PDO PHP 扩展。

安装

可以通过 Composer 安装此包

composer require yiisoft/mutex-pdo-pgsql

通用用法

此包提供了两个类,实现了来自 yiisoft/mutex 包的 MutexInterfaceMutexFactoryInterface

/**
 * @var \PDO $connection Configured for PostgreSQL.
 */

$mutex = new \Yiisoft\Mutex\Pgsql\PgsqlMutex('mutex-name', $connection);

$mutexFactory = new \Yiisoft\Mutex\Pgsql\PgsqlMutexFactory($connection);

你可以使用多种方式使用此包。你可以在同步模式下执行回调,即同时只执行一个回调实例

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

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

另一种方式是手动打开和关闭互斥锁

$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');

这可以在较低级别完成

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

如果你想要更多的控制,你可以手动获取互斥锁

$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();

PgsqlMutex 支持等待一定时间的锁功能。使用 withRetryDelay() 方法,你可以覆盖每次尝试之间的毫秒数,直到指定超时时间超时

$mutex = $mutex->withRetryDelay(100);

默认情况下,它是 50 毫秒 - 这意味着我们可能每秒尝试获取锁多达 20 次。

文档

如果你需要帮助或有问题,Yii 论坛 是一个很好的地方。你也可以查看其他 Yii 社区资源

许可证

Yii Mutex 库 - PostgreSQL PDO 驱动是自由软件。它根据 BSD 许可证的条款发布。有关更多信息,请参阅 LICENSE

Yii 软件 维护。

支持项目

Open Collective

关注更新

Official website Twitter Telegram Facebook Slack