lib/FKSE/Process/ProcessPool.php
public function start()
    {
        foreach ($this->processes as $process) {
            //start process
            $process->start();

            //update status array
            $this->updateStatus();

            while ($this->runningProcesses() >= $this->concurrent) {
                usleep(self::SLEEP_INTERVAL);
                //update status
                $this->updateStatus();
            }
        }
        //wait until all processes are finished
        $this->wait();
    }
public function start()
    {
        foreach ($this->processes as $process) {
            //start process
            $process->start();

            //update status array
            $this->updateStatus();

            while ($this->runningProcesses() >= $this->concurrent) {
                usleep(self::SLEEP_INTERVAL);
                //update status
                $this->updateStatus();
            }
        }
        //wait until all processes are finished
        $this->wait();
    }
public function start ( ) { foreach ( $ this -> processes as $ process ) { //start process $ process -> start ( ) ; //update status array $ this -> updateStatus ( ) ; while ( $ this -> runningProcesses ( ) >= $ this -> concurrent ) { usleep ( self :: SLEEP_INTERVAL ) ; //update status $ this -> updateStatus ( ) ; } } //wait until all processes are finished $ this -> wait ( ) ; }
Start the processes in the pool
Start the processes in the pool