mitsuru793 / symfony-parallel-process
使用 Symfony Process 组件启用并行处理的一个简单包装器
v2.1.0
2018-09-20 09:02 UTC
Requires
- symfony/process: ~4.0
Requires (Dev)
- phpunit/phpunit: ~7.3
This package is auto-updated.
Last update: 2024-09-20 22:28:09 UTC
README
这是一个使用 Symfony Process 组件启用并行处理的一个简单包装器。
安装
composer require mitsuru793/symfony-parallel-process
示例
<?php use Symfony\Component\Process\Process; use Jack\Symfony\ProcessManager; $proc1 = new Process('ls -l'); $proc2 = new Process('ls -l'); $procManager = new ProcessManager(); $processes = array(); array_push($processes, $proc1, $proc2); $maxParallelProcesses = 5; $pollingInterval = 1000; // microseconds $callback = function (string $type, string $data, Process $process) { // do streaming }; $procManager->runParallel($processes, $maxParallelProcesses, $pollingInterval, $callback);
非常感谢
分支
https://github.com/jagandecapri/symfony-parallel-process
runParallel 的回调参数
https://github.com/chubidu/symfony-parallel-process