1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
|
<?php
declare(strict_types=1);
namespace malkusch\lock\mutex;
use Memcached;
/**
* Memcached based spinlock implementation.
*
* @author Markus Malkusch <markus@malkusch.de>
* @link bitcoin:1P5FAZ4QhXCuwYPnLZdk3PJsqePbu1UDDA Donations
* @license WTFPL
*/
class MemcachedMutex extends SpinlockMutex
{
/**
* @var Memcached The connected Memcached API.
*/
private $memcache;
/**
* Sets the lock's name and the connected Memcached API.
*
* The Memcached API needs to have at least one server in its pool. I.e.
* it has to be added with Memcached::addServer().
*
* @param string $name The lock name.
* @param Memcached $memcache The connected Memcached API.
* @param int $timeout The time in seconds a lock expires, default is 3.
*
* @throws \LengthException The timeout must be greater than 0.
*/
public function __construct(string $name, Memcached $memcache, int $timeout = 3)
{
parent::__construct($name, $timeout);
$this->memcache = $memcache;
}
protected function acquire(string $key, int $expire): bool
{
return $this->memcache->add($key, true, $expire);
}
protected function release(string $key): bool
{
return $this->memcache->delete($key);
}
}
|
