0

我在让 PHP libevent 扩展在超时时跳​​出循环时遇到了一些困难。这是我到目前为止基于 PHP.net 文档页面上的演示所获得的内容：

// From here: http://www.php.net/manual/en/libevent.examples.php

function print_line($fd, $events, $arg) {
    static $max_requests = 0;
    $max_requests++;

    printf("Received event: %s after %s\n%s", implode(getEventFlags($events)), getTimer(), fgets($fd));

    if ($max_requests == 10) {
        // exit loop after 3 writes
        echo " [EXIT]\n";
        event_base_loopexit($arg[1]);
    }
}

// create base and event
$base = event_base_new();
$event = event_new();


getTimer(); // Initialise time

$fd = STDIN;
event_set($event, $fd, EV_READ | EV_PERSIST, "print_line", array($event, $base));
event_base_set($event, $base);
event_add($event, 2000000);
event_base_loop($base);

// extract flags from bitmask
function getEventFlags ($ebm) {
    $expFlags = array('EV_TIMEOUT', 'EV_SIGNAL', 'EV_READ', 'EV_WRITE', 'EV_PERSIST');
    $ret = array();
    foreach ($expFlags as $exf) {
        if ($ebm & constant($exf)) {
            $ret[] = $exf;
        }
    }
    return $ret;
}

// Used to track time!
function getTimer () {
    static $ts;
    if (is_null($ts)) {
        $ts = microtime(true);
        return "Timer initialised";
    }
    $newts = microtime(true);
    $r = sprintf("Delta: %.3f", $newts - $ts);
    $ts = $newts;
    return $r;
}

我可以看到event_add传递给 print_line() 的事件的超时值，如果这些事件相隔超过 2 秒，我会得到一个EV_TIMEOUT而不是EV_READ. 然而，我想要的是让 libevent 在print_line达到超时后立即调用，而不是等待下一个事件来给我超时。

我试过使用event_base_loopexit($base, 2000000)，这会导致事件循环立即退出而不阻塞事件。我也尝试过传递EV_TIMEOUT给event_set，这似乎根本没有效果。

有没有人设法让这个工作？我知道 event_buffer_* 东西适用于超时，但是我想使用标准event_base函数。其中一个PECL 错误谈到了 event_timer_* 函数，这些函数确实存在于我的系统上，但是它们根本没有记录在案。

4

1 回答 1

0

问题出在 fgets() 中：

printf("Received event: %s after %s\n%s", implode(getEventFlags($events)), getTimer(), fgets($fd));

这会阻止处理并等待来自 STDIN 的数据（但没有超时）

改成这样的：

$text = '';
if ($events & EV_READ) {
    $text = fgets($fd);
}
printf("Received event: %s after %s\n%s", implode(getEventFlags($events)), getTimer(), $text);
于 2012-03-11T22:03:17.027 回答