Время ожидания выполнения процесса PHP

У меня такой код:

/**
 * Executes a program and waits for it to finish, taking pipes into account.
 * @param string $cmd Command line to execute, including any arguments.
 * @param string $input Data for standard input.
 * @param integer $timeout How much to wait from program in msecs (-1 to wait indefinitely).
 * @return array Array of "stdout", "stderr" and "return".
 */
function execute($cmd,$stdin=null,$timeout=-1){
    $proc=proc_open(
        $cmd,
        array(array('pipe','r'),array('pipe','w'),array('pipe','w')),
        $pipes=null
    );
    fwrite($pipes[0],$stdin);                  fclose($pipes[0]);
    $stdout=stream_get_contents($pipes[1]);    fclose($pipes[1]);
    $stderr=stream_get_contents($pipes[2]);    fclose($pipes[2]);
    $return=proc_close($proc);
    return array(
        'stdout' => $stdout,
        'stderr' => $stderr,
        'return' => $return
    );
}

У него две "проблемы".

  • Код синхронный; он зависает до закрытия целевого процесса.
  • До сих пор мне не удавалось «зависнуть» без ввода другой команды (например, $cmd > /dev/null & в Linux и start /B $cmd в Windows)

Я вообще не против "заморозки". Мне просто нужно реализовать этот тайм-аут.

Примечание. Важно, чтобы решение было кроссплатформенным. Также важно, чтобы $cmd не нужно было менять — я запускаю несколько сложных команд и боюсь, что могут возникнуть проблемы, однако это зависит от типа исправления — я рад их услышать. , просто я бы предпочел другую альтернативу.

Я нашел некоторые ресурсы, которые могут помочь:


php timeout process proc-open
person Christian    schedule 15.03.2011    source источник

Ответы (3)


arrow_upward
2
arrow_downward

В коде есть несколько ошибок.

Это действительно работает:

function execute($cmd, $stdin = null, $timeout = -1)
{
    $proc=proc_open(
        $cmd,
        array(array('pipe','r'), array('pipe','w'), array('pipe','w')),
        $pipes
    );
    var_dump($pipes);
    if (isset($stdin))
    {
        fwrite($pipes[0],$stdin);
    }
    fclose($pipes[0]);

    stream_set_timeout($pipes[1], 0);
    stream_set_timeout($pipes[2], 0);

    $stdout = '';

    $start = microtime();

    while ($data = fread($pipes[1], 4096))
    {
        $meta = stream_get_meta_data($pipes[1]);
        if (microtime()-$start>$timeout) break;
        if ($meta['timed_out']) continue;
        $stdout .= $data;
    }

    $stdout .= stream_get_contents($pipes[1]);
    $stderr = stream_get_contents($pipes[2]);
    $return = proc_close($proc);

    return array(
        'stdout' => $stdout,
        'stderr' => $stderr,
        'return' => $return
    );
}
person Alex    schedule 06.05.2013
comment
Если я запускаю execute('php test.php', 3), а test.php спит в течение 30 секунд без вывода, эта функция блокируется на неопределенный срок. - person EricP; 03.02.2020

arrow_upward
1
arrow_downward

Вместо stream_get_contents вы можете использовать fread, чтобы получить более точный контроль над тем, что делает ваш код. Это в сочетании с stream_set_timeout может дать вам то, что вы ищете.

Я собрал кое-что в качестве демонстрации того, что, по моему мнению, может сработать — этот код полностью непроверен и не дает никаких гарантий, но может направить вас в правильном направлении. ;)

function execute($cmd,$stdin=null,$timeout=-1){
    $proc=proc_open(
        $cmd,
        array(array('pipe','r'),array('pipe','w'),array('pipe','w')),
        $pipes=null
    );
    fwrite($pipes[0],$stdin);                  fclose($pipes[0]);

    stream_set_timeout($pipes[1], 0);
    stream_set_timeout($pipes[2], 0);

    $stdout = '';

    $start = microtime();

    while ($data = fread($pipes[1], 4096))
    {
        $meta = stream_get_meta_data($pipes[1]);
        if (microtime()-$start>$timeout) break;
        if ($meta['timed_out']) continue;
        $stdout .= $data;
    }

    $return = proc_close($proc);
    $stdout .= stream_get_contents($pipes[1]);
    $stderr = stream_get_contents($pipes[2]);

    return array(
        'stdout' => $stdout,
        'stderr' => $stderr,
        'return' => $return
    );
}
person NuclearDog    schedule 15.03.2011

arrow_upward
0
arrow_downward

Кажется, это работает для меня:

public function toPDF() {
    $doc = $this->getDocument();

    $descriptor = [
        ['pipe','r'],
        ['pipe','w'],
        ['file','/dev/null','w'], // STDERR
    ];
    $proc = proc_open('/usr/local/project/scripts/dompdf_cli.php',$descriptor,$pipes,sys_get_temp_dir());
    fwrite($pipes[0],"$doc[paper]\n$doc[html]");
    fclose($pipes[0]);

    $timeout = 30;

    stream_set_blocking($pipes[1], false);

    $pdf = '';

    $now = microtime(true);

    try {
        do {
            $elapsed = microtime(true) - $now;

            if($elapsed > $timeout) {
                throw new \Exception("PDF generation timed out after $timeout seconds");
            }
            $data = fread($pipes[1], 4096);
            if($data === false) {
                throw new \Exception("Read failed");
            }
            if(strlen($data) === 0) {
                usleep(50);
                continue;
            }
            $pdf .= $data;
        } while(!feof($pipes[1]));

        fclose($pipes[1]);
        $ret = proc_close($proc);
    } catch(\Exception $ex) {
        fclose($pipes[1]);
        proc_terminate($proc); // proc_close tends to hang if the process is timing out
        throw $ex;
    } 


    if($ret !== 0) {
        throw new \Exception("dompdf_cli returned non-zero exit status: $ret");
    }

    // dump('returning pdf');
    return $pdf;
}

Я не уверен, какова цель stream_set_timeout - это просто устанавливает время ожидания для каждого чтения, но если вы хотите ограничить общее время, вам просто нужно установить поток в неблокирующий режим, а затем определить, как долго он берет.

person mpen    schedule 12.12.2016