src/Utils/ProcessManager.php
private function addPending()
    {
        while (count($this->inProcess) < $this->concurrency) {

            $item = $this->getUnprocessed();

            if (empty($item)) {

                break;
            }

            $this->inProcess[$item['index']] = $item['process'];

            $item['process']->start();

            if (count($this->inProcess) >= $this->concurrency) {

                break;
            }
        }
    }
private function addPending()
    {
        while (count($this->inProcess) < $this->concurrency) {

            $item = $this->getUnprocessed();

            if (empty($item)) {

                break;
            }

            $this->inProcess[$item['index']] = $item['process'];

            $item['process']->start();

            if (count($this->inProcess) >= $this->concurrency) {

                break;
            }
        }
    }
private function addPending ( ) { while ( count ( $ this -> inProcess ) < $ this -> concurrency ) { $ item = $ this -> getUnprocessed ( ) ; if ( empty ( $ item ) ) { break ; } $ this -> inProcess [ $ item [ 'index' ] ] = $ item [ 'process' ] ; $ item [ 'process' ] -> start ( ) ; if ( count ( $ this -> inProcess ) >= $ this -> concurrency ) { break ; } } }
Adds the pending
Adds the pending