andytruong/php-pool

此包的官方仓库似乎已消失,因此该包已被冻结。

dev-master 2019-01-09 00:36 UTC

This package is auto-updated.

Last update: 2023-02-09 10:47:22 UTC


README

使用有限线程并行运行任务。

示例用法

<?php
$pool = new andytruong\pool\Pool($poolSize = 3);

$tasks = [1, 2, 3, 4, 5];
foreach ($tasks as $task) {
    $pool->execute(
        function($task) {
            echo "[callback] processing {$task}" . PHP_EOL;
            sleep(5); # slow task process
            echo "[callback] completed {$task}" . PHP_EOL;
        },
        [$task]
    );
}

$pool->wait();

安装

composer require andytruong/php-pool