<?php

require_once __DIR__ . '/vendor/autoload.php';

$workers = 10;
$jobs = 1000;

$pool = new \Wulsic\Pool\Pool($workers);

echo "Worker count: $workers" . PHP_EOL;

$start = microtime(true);

for($i = 0; $i < $jobs; $i++) {
    echo "Job $i" . PHP_EOL;
    $pool->submit(
        function ($taskId) {
            print "Active task: $taskId" . PHP_EOL;
            return "Finished task: $taskId";
        },
        [$i]
    );
}

while($pool->collect()) {
    continue;
}

$pool->shutdown();

printf(
    "Finished %s threads in %.2f seconds\n",
    $workers ? "with {$workers}" : "without",
    microtime(true) - $start
);

许可证

本包所有内容均受 [MIT 许可证] 许可。