kelunik/

redis-mutex

维护者

详细信息

github.com/kelunik/redis-mutex

源代码

问题

安装量: 1,817

依赖: 0

推荐: 0

安全: 0

星标: 7

关注者: 2

分支: 3

开放问题: 1

v0.2.2 2019-01-20 21:25 UTC

Requires

Requires (Dev)

MIT c1f0cbbdf545a010d618b7f84e0e3b169f5c2125

  • Niklas Keller <me.woop@kelunik.com>

This package is auto-updated.

Last update: 2024-09-21 19:50:22 UTC

README

基于 Amp并发框架 和 Redis 的分布式互斥锁。

基本示例

$mutex = new Mutex(...);

// ...

try {
    $token = bin2hex(random_bytes(16));
    yield $mutex->lock($sessionId, $token);

    // Code here will only be executed in one client at a time.
    // If it takes longer than your specified TTL, you have to
    // renew the lock, see next example.

    yield $mutex->unlock($sessionId, $token);
} catch (MutexException $e) {
    // ...
}

更新示例

$mutex = new Mutex(...);
$locks = [];

Loop::repeat(1000, function () use ($mutex, $locks) {
    foreach ($locks as $id => $token) {
        $mutex->renew($id, $token);
    }
});

// ...

try {
    $token = bin2hex(random_bytes(16));
    yield $mutex->lock($sessionId, $token);
    $locks[$sessionId] = $token;

    // Code here will only be executed in one client at a time.
    // Your lock will automatically be renewed by the reactor
    // repeat above. Don't do blocking things here (you should never
    // do that with Amp anyway), otherwise the reactor will not
    // be able to schedule the renewal.

    unset($locks[$sessionId]);
    yield $mutex->unlock($sessionId, $token);
} catch (MutexException $e) {
    // ...
}