saxulum/saxulum-processes-executor

Saxulum Processes Executor

saxulum-processes-executor

, _(*1)

Description

A simple to use process executor., _(*2)

Requirements

• php: ~7.0
• psr/log: ~1.0
• symfony/process: ~4.0|~3.0|~2.8

Installation

Through Composer as [saxulum/saxulum-processes-executor][1]., _(*3)

Usage

Simple use without any callbacks

```{.php} <?php, <sub>(*4)</sub>

use Symfony\Component\Process\Process; use Saxulum\ProcessesExecutor\ProcessesExecutor;, <sub>(*5)</sub>

$processes = [ new Process('php subprocess1.php'), new Process('php subprocess2.php'), new Process('php subprocess3.php'), new Process('php subprocess4.php'), new Process('php subprocess5.php'), ];, <sub>(*6)</sub>

$startedCommandLines = [];, <sub>(*7)</sub>

$executor = new ProcessesExecutor(); $executor->execute($processes);, <sub>(*8)</sub>

### With start callback (get called onces per process)

```{.php}
<?php

use Symfony\Component\Process\Process;
use Saxulum\ProcessesExecutor\ProcessesExecutor;

$processes = [
    new Process('php subprocess1.php'),
    new Process('php subprocess2.php'),
    new Process('php subprocess3.php'),
    new Process('php subprocess4.php'),
    new Process('php subprocess5.php'),
];

$startedCommandLines = [];

$executor = new ProcessesExecutor();
$executor->execute(
    $processes,
    function (Process $process, $key) use (&$startedProcesses) {
        $startedCommandLines[$key] = $process->getCommandLine();
    }
);

With iteration callback (get called onces per iteration)

```{.php} <?php, <sub>(*9)</sub>

use Symfony\Component\Process\Process; use Saxulum\ProcessesExecutor\ProcessesExecutor;, <sub>(*10)</sub>

$processes = [ new Process('php subprocess1.php'), new Process('php subprocess2.php'), new Process('php subprocess3.php'), new Process('php subprocess4.php'), new Process('php subprocess5.php'), ];, <sub>(*11)</sub>

$outputs = []; $errorOutputs = [];, <sub>(*12)</sub>

$executor = new ProcessesExecutor(); $executor->execute( $processes, null, function (array $processes) use (&$outputs, &$errorOutputs) { foreach ($processes as $key => $process) { /** @var Process $process */ if ('' !== $output = $process->getIncrementalOutput()) { if (!isset($outputs[$key])) { $outputs[$key] = ''; }, <sub>(*13)</sub>

            $outputs[$key] .= $output;
        }
        if ('' !== $errorOutput = $process->getIncrementalErrorOutput()) {
            if (!isset($outputs[$key])) {
                $errorOutputs[$key] = '';
            }

            $errorOutputs[$key] .= $errorOutput;
        }
    }
}

);, <sub>(*14)</sub>

### With finish callback (get called onces per process)

```{.php}
<?php

use Symfony\Component\Process\Process;
use Saxulum\ProcessesExecutor\ProcessesExecutor;

$processes = [
    new Process('php subprocess1.php'),
    new Process('php subprocess2.php'),
    new Process('php subprocess3.php'),
    new Process('php subprocess4.php'),
    new Process('php subprocess5.php'),
];

$outputs = [];
$errorOutputs = [];

$executor = new ProcessesExecutor();
$executor->execute(
    $processes,
    null,
    null,
    function (Process $process, $key) use (&$outputs, &$errorOutputs) {
        if ('' !== $output = $process->getOutput()) {
            $outputs[$key] = $output;
        }
        if ('' !== $errorOutput = $process->getErrorOutput()) {
            $errorOutputs[$key] = $errorOutput;
        }
    }
);

Copyright

Dominik Zogg 2016, <sub>(*15)</sub>