public function apply($func = null)
    {
        // add new function to pending queue
        if ($func !== null) {
            if ($func instanceof \Closure or $func instanceof ProcessInterface or is_callable($func)) {
                $this->pending[] = func_get_args();
            } else {
                throw new \UnexpectedValueException("Parameter 1 in ProcessPool#apply must be a Closure or callable");
            }
        }

        // start a new worker if our current worker queue is low
        if (!empty($this->pending) and count($this->workers) < $this->max) {
            call_user_func_array(array($this, 'create'), array_shift($this->pending));
        }

        return $this;
    }
public function apply($func = null)
    {
        // add new function to pending queue
        if ($func !== null) {
            if ($func instanceof \Closure or $func instanceof ProcessInterface or is_callable($func)) {
                $this->pending[] = func_get_args();
            } else {
                throw new \UnexpectedValueException("Parameter 1 in ProcessPool#apply must be a Closure or callable");
            }
        }

        // start a new worker if our current worker queue is low
        if (!empty($this->pending) and count($this->workers) < $this->max) {
            call_user_func_array(array($this, 'create'), array_shift($this->pending));
        }

        return $this;
    }
public function apply ( $ func = null ) { // add new function to pending queue if ( $ func !== null ) { if ( $ func instanceof \ Closure or $ func instanceof ProcessInterface or is_callable ( $ func ) ) { $ this -> pending [ ] = func_get_args ( ) ; } else { throw new \ UnexpectedValueException ( "Parameter 1 in ProcessPool#apply must be a Closure or callable" ) ; } } // start a new worker if our current worker queue is low if ( ! empty ( $ this -> pending ) and count ( $ this -> workers ) < $ this -> max ) { call_user_func_array ( array ( $ this , 'create' ) , array_shift ( $ this -> pending ) ) ; } return $ this ; }
Apply a worker to the working or pending queue

@param Callable $func Callback function to fork into.
@return ProcessPool
Apply a worker to the working or pending queue