Yiisoft\Mutex\RetryAcquireTrait

Complexity

Total Complexity

4

Size/Duplication

Total Lines	27
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	retryAcquire()	0	11	3
A	withRetryDelay()	0	5	1

<?php

declare(strict_types=1);

namespace Yiisoft\Mutex;

use Closure;

/**
 * Allows retrying acquire with a certain timeout.
 */
trait RetryAcquireTrait
{
    /**
     * @var int Number of milliseconds between each try until specified timeout times out.
     * By default, it is 50 milliseconds - it means that we may try to acquire lock up to 20 times per
     * second.
     */
    private int $retryDelay = 50;

    public function withRetryDelay(int $retryDelay): self
    {
        $new = clone $this;
        $new->retryDelay = $retryDelay;
        return $new;
    }

    private function retryAcquire(int $timeout, Closure $callback): bool
    {
        $start = microtime(true);
        do {
            if ($callback()) {
                return true;
            }
            usleep($this->retryDelay * 1000);
        } while (microtime(true) - $start < $timeout);

        return false;
    }
}