Server : ApacheSystem : Linux host.digitalbabaji.in 4.18.0-513.11.1.el8_9.x86_64 #1 SMP Wed Jan 17 02:00:40 EST 2024 x86_64 User : addictionfreeind ( 1003) PHP Version : 7.2.34 Disable Function : exec,passthru,shell_exec,system Directory : /home/addictionfreeind/public_html/admin1/vendor/amphp/sync/src/ |
Upload File : |
<?php
namespace Amp\Sync;
use Amp\Promise;
use function Amp\call;
final class LocalKeyedSemaphore implements KeyedSemaphore
{
/** @var LocalSemaphore[] */
private $semaphore = [];
/** @var int[] */
private $locks = [];
/** @var int */
private $maxLocks;
public function __construct(int $maxLocks)
{
$this->maxLocks = $maxLocks;
}
public function acquire(string $key): Promise
{
if (!isset($this->semaphore[$key])) {
$this->semaphore[$key] = new LocalSemaphore($this->maxLocks);
$this->locks[$key] = 0;
}
return call(function () use ($key) {
$this->locks[$key]++;
/** @var Lock $lock */
$lock = yield $this->semaphore[$key]->acquire();
return new Lock(0, function () use ($lock, $key) {
if (--$this->locks[$key] === 0) {
unset($this->semaphore[$key], $this->locks[$key]);
}
$lock->release();
});
});
}
}