如何优雅停止生成器？基于PHP事件循环代码的疑问

你说得没错，原代码里直接调用Loop::stop()会让事件循环在下一个tick终止，这会粗暴地中断正在进行的HTTP请求——可能导致请求半途而废、job状态不一致（比如已经处理了请求但没来得及删除job），完全称不上"优雅停止"。

要实现真正的优雅退出，核心思路是先标记退出状态，等待当前正在处理的任务完成后再终止循环，同时停止接收新任务。下面是具体的实现方案：

步骤1：引入退出标志 #

首先定义一个可被闭包访问的退出标志，用来标记程序是否需要开始优雅退出流程：

$shutdownInitiated = false;

步骤2：修改SIGINT回调逻辑 #

收到SIGINT时，不要立即停止循环，而是设置退出标志，同时可以暂停Beanstalk的任务接收（避免拉取新的job）：

Loop::onSignal(SIGINT, function () use (&$shutdownInitiated) {
    echo "Caught SIGINT! Starting graceful shutdown...\n";
    $shutdownInitiated = true;
    // 可选：暂停Beanstalk队列的任务接收，不再获取新job
    // $beanstalk->pauseTube('your-target-tube');
});

步骤3：调整循环逻辑，处理退出标志 #

在主循环中，先检查退出标志，再决定是否继续获取新任务；同时确保当前正在处理的job（包括HTTP请求）完成后，再退出循环：

Loop::run(function() use (&$shutdownInitiated, $beanstalk, $httpClient, $request) {
    // 上面的SIGINT回调放在这里
    
    while (!$shutdownInitiated && [$jobId, $jobData] = yield $beanstalk->reserve()) {
        try {
            // 等待当前HTTP请求完成，无论成功失败
            $response = yield $httpClient->send($request);
            // 请求成功，删除job
            yield $beanstalk->delete($jobId);
            echo "Job $jobId processed successfully\n";
        } catch (\Exception $e) {
            // 请求失败，将job放回队列（根据业务需求调整）
            yield $beanstalk->release($jobId);
            echo "Job $jobId failed: {$e->getMessage()}\n";
        }
    }

    // 所有pending任务处理完毕，正式停止事件循环
    echo "All in-progress jobs completed. Exiting gracefully...\n";
    Loop::stop();
});

可选：添加强制退出超时 #

如果担心某些HTTP请求耗时过长（比如卡住），可以在优雅退出流程中加入超时机制，超时后强制终止程序：

Loop::onSignal(SIGINT, function () use (&$shutdownInitiated) {
    echo "Caught SIGINT! Starting graceful shutdown... Will force exit in 5 seconds.\n";
    $shutdownInitiated = true;
    
    // 5秒后强制停止循环，避免无限等待
    Loop::addTimer(5, function() {
        echo "Graceful shutdown timeout reached. Forcing exit...\n";
        Loop::stop();
    });
});

关键细节说明 #

• 不要中断正在执行的请求：除非你的业务允许中途放弃请求，否则一定要等待$httpClient->send()的yield完成，保证job的处理状态一致。
• 停止接收新任务：通过暂停Beanstalk的tube或者在循环条件中检查退出标志，避免在优雅退出过程中获取新的job，延长退出时间。
• 异常处理：务必给HTTP请求和Beanstalk操作加上try-catch，确保即使请求失败，job也能被正确处理（放回队列或标记失败），避免数据丢失。

内容的提问来源于stack exchange，提问作者gedi