reactphp-x/limiter-concurrent

Maintainers

Details

github.com/reactphp-x/limiter-concurrent

Source

Issues

Installs: 25

Dependents: 0

Suggesters: 0

Security: 0

Stars: 0

Watchers: 0

Forks: 0

Open Issues: 0

v1.0.0 2024-09-16 05:18 UTC

Requires

MIT 8c4954ac5ea1c488005f6d515893b689f440cbc6

  • wpjscc <wpjscc.woop@gmail.com>

This package is auto-updated.

Last update: 2024-12-16 05:47:22 UTC

README

install

composer require reactphp-x/limiter-concurrent -vvv

Usage

use ReactphpX\LimiterConcurrent\LimiterConcurrent;
use React\EventLoop\Loop;
use React\Promise\Deferred;
use function React\Async\delay;


// 10 request per second but not in order
$limiterConcurrent = new LimiterConcurrent(10, 1000);


$start = microtime(true);
for ($i = 0; $i < 100; $i++) {
    $limiterConcurrent->concurrent(function () use ($i) {
        $deferred = new Deferred();
        Loop::addTimer(0.1 * random_int(1, 10), function () use ($deferred, $i) {
            $deferred->resolve($i);
        });
        return $deferred->promise();
    })->then(function ($i) use ($start) {
        $end = microtime(true);
        echo "then $i " . ($end - $start) . "\n";
    });
}

delay(12);

// 10 request per second in order
$limiterConcurrent = new LimiterConcurrent(10, 1000, true);

$start = microtime(true);
for ($i = 0; $i < 100; $i++) {
    $limiterConcurrent->concurrent(function () use ($i) {
        $deferred = new Deferred();
        Loop::addTimer(0.1 * random_int(1, 10), function () use ($deferred, $i) {
            $deferred->resolve($i);
        });
        return $deferred->promise();
    })->then(function ($i) use ($start) {
        $end = microtime(true);
        echo "queue then $i " . ($end - $start) . "\n";
    });
}

License

MIT