gistfile1.txt

/**
     * Enqueue
     *
     * @param Locker $locker
     * @param string $resourceID
     * @param float $timeout
     *
     * @return PromiseInterface
     */
    public function enqueue(
        Locker $locker,
        string $resourceID,
        float $timeout
    ) : PromiseInterface
    {
        return $this
            ->client
            ->eval('
                local resource = ARGV[1];
                local locker = ARGV[2];
                local hash = resource .. ".hash";
                local channel = resource .. ".channel";
                local len = redis.call("hlen", hash);
                redis.call(hset, hash, locker, true);
                if (len == 0) then
                    redis.call("lpush", channel, '.');
                end
            ', 1, $resourceID, $locker->ID())
            ->then(function() use ($resourceID, $timeout) {
                var_dump('SI');
                return $this
                    ->client
                    ->blpop($resourceID . '.channel', $timeout);
            });
    }
    
    /**
     * Release
     *
     * @param Locker $locker
     * @param string $resourceID
     *
     * @return PromiseInterface
     */
    public function release(
        Locker $locker,
        string $resourceID
    ) : PromiseInterface
    {
        $promise = new FulfilledPromise();

        if ($locker->owns()) {
            $promise->then(function() use ($resourceID, $locker) {

                return $this
                    ->client
                    ->eval('
                        local resource = ARGV[1];
                        local locker = ARGV[2];
                        local hash = resource .. ".hash";
                        local channel = resource .. ".channel";
                        local len = redis.call("hlen", hash);
                        redis.call(hdel, hash, locker);
                        if (len > 0) then
                            redis.call("lpush", channel, ".");
                        end
                    ', 1, $resourceID, $locker->ID());
            });
        }

        return $promise;
    }

gistfile2.txt

$promise = $locker
                ->enqueue()
                ->then(function(Locker $locker) use (&$finished, &$current, $loop, $client) {

                    $this->assertEquals($current, 0);
                    $current++;
                    $finished++;

                    return $client
                        ->get('http://google.es')
                        ->then(function() use (&$current, $locker) {
                            $this->assertEquals($current, 1);
                            $current--;

                            return $locker;
                        });
                })
                ->then(function(Locker $locker) {
                    return $locker->release();
                });
               
               
        $loop->run();
        Block\await($promise, $loop);