PHP stream_select 怎样保存循环中的剩余超时时间

如果把固定的 stream_select() 超时时间直接放进循环，每轮调用都会重新获得一段完整等待时间，整个循环就可能比预期拖得更久。保存“剩余超时时间”的关键不是修改 PHP 内部状态，而是先确定一个截止时刻；每轮开始时用当前时间重新计算剩余微秒数，再拆成秒和微秒传给选择器。

官方文档：https://www.php.net/manual/en/function.stream-select.php

下面的示例只围绕一个读取循环展开：监听数组每次都从原始集合复制，超时每次都由截止时间计算。示例输出是根据代码逻辑推导的说明，不代表本文发布前执行过该程序。

不要把“本轮最多等多久”和“整个循环最多持续多久”混成一个变量。前者可以固定，后者必须由截止时间减去当前时间得到。

先把一次等待和总预算分开

stream_select() 的 seconds 与 microseconds 共同组成一次等待的上限，返回 0 表示本次没有流变为就绪，返回正数表示修改后的监听数组里有可处理的流，返回 false 表示调用出错。它不会替循环保存一个“还剩多少时间”的变量。

因此可以把总预算记成 deadline。循环里只做一件时间相关的事：remaining = deadline - microtime(true)。如果剩余值不大于零，直接结束；否则再把它拆成参数。

这段代码最重要的两个变量是 $deadline 和 $originalRead。前者控制全局上限，后者保证下一轮不会因为本次调用删掉未就绪的流。若只把 $seconds 写成固定值，循环就会在每次返回后重新开始一段完整等待。

为什么每轮都要重建监听数组

传给 stream_select() 的数组是输入也是输出：函数返回时，$read 只保留当前可读的流，原来的未就绪成员会被移除。把这份已经被改写的数组直接带进下一轮，会让监听集合逐渐缩小，甚至变成空集合。

正确的边界是“原始集合负责保存意图，工作集合负责承接本轮结果”。$write 和 $except 也遵循同一规则；不监听某类事件时传 null 即可。

 0) {
    $read = $originalRead;
    $write = null;
    $except = null;

    // 监听集合不能沿用上一轮的返回数组。
    $sec = (int) floor($left);
    $usec = (int) floor(($left - $sec) * 1_000_000);
    $count = stream_select($read, $write, $except, $sec, $usec);

    if ($count === false) {
        // 错误路径不要把被改写的数组当作下一轮输入。
        throw new RuntimeException('stream_select failed');
    }
    if ($count === 0) {
        // 超时没有就绪流，下一轮仍以 deadline 计算剩余时间。
        continue;
    }

    foreach ($read as $ready) {
        // 只消费本次返回的就绪流，原始集合仍保持不变。
        consume($ready);
    }
}
?>

若业务要求收到第一个事件就结束，可以在 foreach 后 break；若要在一个总预算内持续收集事件，就保留循环，并继续重建数组。两种需求的共同点是：不能用返回后的工作数组替代原始集合。

用指标确认超时没有被循环重置

这个问题适合用基线和结果对比来判断，而不是凭感觉看循环是否“变快”。假设总预算为 2.5 秒，期间出现三次可读事件：修复前每轮又传入 2.5 秒，最坏等待上限接近 7.5 秒；修复后每轮传入截止时间减去当前时间，整个等待预算仍约为 2.5 秒，处理事件所占时间会让剩余等待自然减少。

建议在业务日志中记录开始时间、截止时间、每次调用前的剩余微秒数、返回值和总循环耗时。这里的指标用于验证时间预算是否按设计递减；不要把某次机器上的耗时当成固定性能承诺。

几个容易让剩余时间失真的边界

• 微秒进位：将小数部分换算为整数微秒时，如果计算结果恰好达到 1,000,000，应重新归一化到下一秒，避免传入不合适的组合。
• 零剩余：剩余时间不大于零时直接退出；不要为了“再检查一次”把零超时放进高频循环，否则会变成忙轮询。
• 返回 false：错误与超时不是同一种结果。记录错误后结束或由上层决定重试，不能把 false 当成 0。
• 空集合：如果没有任何要监听的流，先按业务决定退出或改用其他等待方式；不要把空集合当成正常事件。
• 读取耗时：foreach 内的处理也会消耗总预算，因此下一轮应该继续从截止时间计算，而不是补回固定时长。

相关问题

为什么不用每轮都传同一个 seconds？ 因为该参数是本次调用的等待上限，函数不会知道你的循环总预算。固定值会随着返回次数重复计算。

stream_select 返回 0 是否就是错误？ 不是。0 表示这次等待到期但没有流就绪；false 才是调用失败，应走错误处理路径。

归纳起来，循环超时的可靠写法只有两条主线：用截止时间保存总预算，用原始集合保存监听意图。每轮从它们派生工作数组和剩余秒、微秒参数，就能避免等待时间被无意重置。