Db3v4l\Service\ProcessManager::runParallel()

Complexity

Conditions	9
Paths	8

Size

Total Lines	39
Code Lines	20

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	1	Features	1

<?php
    public function runParallel(array $processes, $maxParallel, $poll = 1000, $callback = null)
    {
        $this->validateProcesses($processes);
        // do not modify the object pointers in the argument, copy to local working variable
        $processesQueue = $processes;
        // fix maxParallel to be max the number of processes or positive
        $maxParallel = min(abs($maxParallel), count($processesQueue));
        // get the first stack of processes to start at the same time
        /** @var Process[] $currentProcesses */

The open comment tag must be the only content on the line

Missing short description in doc comment

The close comment tag must be the only content on the line

        $currentProcesses = array_splice($processesQueue, 0, $maxParallel);
        // start the initial stack of processes
        foreach ($currentProcesses as $idx => $process) {
            $process->start(function ($type, $buffer) use ($callback, $idx, $process) {

The opening parenthesis of a multi-line function call should be the last content on the line.

                if ($callback) {
                    $callback($type, $buffer, $idx, $process);
                }
            });

For multi-line function calls, the closing parenthesis should be on a new line.

        }
        do {
            // wait for the given time
            usleep($poll);
            // remove all finished processes from the stack
            foreach ($currentProcesses as $index => $process) {
                if (!$process->isRunning()) {
                    unset($currentProcesses[$index]);
                    // directly add and start new process after the previous finished
                    if (count($processesQueue) > 0) {
                        $nextProcess = array_shift($processesQueue);
                        $nextProcess->start(function ($type, $buffer) use ($callback, $nextProcess) {

The opening parenthesis of a multi-line function call should be the last content on the line.

                            if ($callback) {
                                $callback($type, $buffer, $nextProcess);
                            }
                        });

For multi-line function calls, the closing parenthesis should be on a new line.

                        $currentProcesses[] = $nextProcess;
                    }
                }
            }
            // continue loop while there are processes being executed or waiting for execution
        } while (count($processesQueue) > 0 || count($currentProcesses) > 0);
    }