graze/parallel-process

run a pool of processes simultaneously

Parallel Process

, _(*1)

Run multiple Symfony\Process's at the same time., _(*2)

, _(*3)

Install

Via Composer, _(*4)

$ composer require graze/parallel-process

If you want to use Tables or Lines to output to the console, include:, _(*5)

$ composer require graze/console-diff-renderer

Usage

``` php $pool = new Pool(); $pool->add(new Process('sleep 100')); $pool->add(new Process('sleep 100')); $pool->add(new Process('sleep 100')); $pool->add(new Process('sleep 100')); $pool->add(new ProcessRun(new Process('sleep 100'))); $pool->run(); // blocking that will run till it finishes, <sub>(*6)</sub>

A Pool will run all child processes at the same time.

### Priority Pool

A Priority pool will sort the runs to allow a prioritised list to be started. You can also limit the number of 
processes to run at a time.

```php
$pool = new PriorityPool();
$pool->add(new Process('sleep 100'), [], 1);
$pool->add(new Process('sleep 100'), [], 0.1);
$pool->add(new Process('sleep 100'), [], 5);
$pool->add(new Process('sleep 100'), [], 10);
$pool->add(new CallbackRun(
    function () {
        return 'yarp';
    },
    [],
    2
);
$pool->run(); // blocking that will run till it finishes

Recursive Pools

You can add a Pool as a child to a parent pool. A Pool will act just like a standard run and hide the child runs., <sub>(*7)</sub>

If the parent is a PriorityPool, it will control all the child runs so that priorities and the max simultaneous configuration options still apply., <sub>(*8)</sub>

$pool = new Pool();
$pool->add(new Process('sleep 100'));
$pool2 = new Pool();
$pool2->add(new Process('sleep 100'));
$pool->add($pool2);
$pool->run(); // blocking that will run till it finishes

Display

You can output runs in a few different ways to the command line. These require the use of the package: graze/console-diff-renderer., <sub>(*9)</sub>

Table

Visual output of the parallel processes, <sub>(*10)</sub>

$pool = new \Graze\ParallelProcess\PriorityPool();
for ($i = 0; $i < 5; $i++) {
    $time = $i + 5;
    $pool->add(new Process(sprintf('for i in `seq 1 %d` ; do date ; sleep 1 ; done', $time)), ['sleep' => $time]);
}
$output = new \Symfony\Component\Console\Output\ConsoleOutput();
$table = new \Graze\ParallelProcess\Display\Table($output, $pool);
$table->run();

, <sub>(*11)</sub>

Lines

Write the output of each process to the screen, <sub>(*12)</sub>

$pool = new \Graze\ParallelProcess\PriorityPool();
$pool->setMaxSimultaneous(3);
for ($i = 0; $i < 5; $i++) {
    $time = $i + 5;
    $pool->add(new Process(sprintf('for i in `seq 1 %d` ; do date ; sleep 1 ; done', $time)), ['sleep' . $time]);
}
$output = new \Symfony\Component\Console\Output\ConsoleOutput();
$lines = new \Graze\ParallelProcess\Display\Lines($output, $pool);
$lines->run();

, <sub>(*13)</sub>

Testing

bash $ make test, <sub>(*14)</sub>

Contributing

Please see CONTRIBUTING for details., <sub>(*15)</sub>

Security

If you discover any security related issues, please email security@graze.com instead of using the issue tracker., <sub>(*16)</sub>

Credits

• Harry Bragg
• All Contributors

License

The MIT License (MIT). Please see License File for more information., <sub>(*17)</sub>