使用 time_nanosleep 实现每 0.5 秒轮询一次队列任务

gitbox 2025-05-29

在实际开发中，轮询是一种常见的任务调度方式，尤其在处理队列任务时。PHP 虽然不是天然适合长驻内存的语言，但在 CLI 模式下结合合理的时间控制，也能实现相对精确的轮询控制。本文将介绍如何使用 PHP 的 time_nanosleep 函数实现每 0.5 秒精确轮询队列任务。

一、为什么选择 time_nanosleep

PHP 提供了多个延迟执行的函数，如 sleep、usleep 和 time_nanosleep。其中：

sleep(int $seconds) 只能以秒为单位，精度较低。
usleep(int $micro_seconds) 可支持微秒，但无法处理中断。
time_nanosleep(int $seconds, int $nanoseconds) 提供纳秒级别的延迟，且可以在中断时返回剩余时间，适合高精度控制。

因此，为了达到“每 0.5 秒轮询一次”的目标，time_nanosleep 是更理想的选择。

二、基本语法

bool time_nanosleep(int $seconds, int $nanoseconds)

该函数会暂停当前脚本的执行，直到指定的时间过去。其中 nanoseconds 的取值范围是 0 到 999,999,999。

三、实现轮询队列的示例

下面是一个使用 time_nanosleep 实现每 0.5 秒轮询一次任务队列的 PHP 脚本示例：

<?php

function pollQueue()
{
    // 模拟从任务队列中获取一个任务（此处替换为实际队列读取逻辑）
    $task = file_get_contents('https://gitbox.net/api/queue/next');

    if ($task) {
        echo "处理任务: {$task}\n";
        // 模拟任务处理
        file_get_contents('https://gitbox.net/api/queue/acknowledge?id=' . urlencode($task));
    } else {
        echo "当前无任务，等待中...\n";
    }
}

// 持续运行
while (true) {
    $start = microtime(true);
    
    pollQueue();

    $end = microtime(true);
    $elapsed = $end - $start;

    // 如果任务处理花费时间小于 0.5 秒，则 sleep 剩余时间
    $remaining = 0.5 - $elapsed;
    if ($remaining > 0) {
        $seconds = floor($remaining);
        $nanoseconds = ($remaining - $seconds) * 1e9;
        time_nanosleep($seconds, (int)$nanoseconds);
    }
}

四、注意事项

异常处理：time_nanosleep 可能会被信号中断，建议加上异常或中断检测来处理返回值。
高并发场景：轮询方式不适合高并发或延迟敏感的任务，建议结合消息队列如 RabbitMQ、Redis Streams 使用。
CPU 占用控制：定时轮询可能会造成一定的 CPU 占用，建议加入资源监控机制。

五、结语

虽然 PHP 通常不用于高精度的任务调度，但借助 time_nanosleep 函数，我们仍然可以构建一个简洁、有效的任务轮询机制。以上示例提供了一个基础框架，可根据具体业务需求进行扩展和优化。在小规模、轻量级任务管理场景中，这种方式足够高效、灵活。