norberttech/symfony-process-executor

Symfony Process Component on steroids, async/sync execution chain.

2.2.0 2025-05-02 10:00 UTC

Requires

• php: ^8.2
• aeon-php/sleep: ^1.0
• symfony/process: ^3.4 || ^4.4 || ^5.0 || ^6.0 || ^7.0

MIT

README

Tiny library that simplifies launching multiple processes in parallel (or not).

Installation

composer require norberttech/symfony-process-executor

Examples

<?php

use NorbertTech\SymfonyProcessExecutor\AsynchronousExecutor;
use NorbertTech\SymfonyProcessExecutor\ProcessPool;
use NorbertTech\SymfonyProcessExecutor\ProcessWrapper;
use Symfony\Component\Process\Process;
use Aeon\Calendar\TimeUnit;

$processes = new ProcessPool(
    Process::fromShellCommandline('sleep 1 && echo 1'),
    Process::fromShellCommandline('sleep 2 && echo 2'),
    Process::fromShellCommandline('sleep 3 && echo 3'),
    Process::fromShellCommandline('sleep 4 && echo 4'),
    Process::fromShellCommandline('sleep 5 && echo 5')
);

$executor = new AsynchronousExecutor(
    pool: $processes,
    sleep: TimeUnit::milliseconds(100), // delay between checking for process completion
    timeout: TimeUnit::seconds(12),  // total timeout for all processes
    batchSize: 2 // number of processes to run in parallel at once, when null all processes will be run in parallel
);

$executor->execute();

$executor->pool()->each(function (ProcessWrapper $processWrapper) {
    var_dump($processWrapper->exitCode());
    var_dump(\trim($processWrapper->output()));
    var_dump($processWrapper->executionTime()->inSeconds());
    var_dump($processWrapper->executionTime()->inMilliseconds());
    var_dump($processWrapper->executionTime()->microsecond());
    echo "----\n";
});

echo \sprintf("Successfully finished child processes: %d\n", $executor->pool()->withSuccessExitCode());
echo \sprintf("Failure finished child processes: %d\n", $executor->pool()->withFailureExitCode());
echo \sprintf("Total execution time [s]: %d\n", $executor->executionTime()->inSecondsPreciseString());

Output:

php examples/async_multiple_success_processes.php 

int(0)
string(1) "1"
int(1)
int(1033)
int(1033295)
----
int(0)
string(1) "2"
int(2)
int(2064)
int(2064680)
----
int(0)
string(1) "3"
int(3)
int(3092)
int(3092137)
----
int(0)
string(1) "4"
int(4)
int(4026)
int(4026060)
----
int(0)
string(1) "5"
int(5)
int(5052)
int(5052531)
----
Successfully finished child processes: 5
Failure finished child processes: 0
Total execution time [s]: 5

Tests

All tests for this library are written as phpt files, you can read more about it here https://qa.php.net/phpt_details.php.

In order to launch full testsuite use composer

composer tests