Boost ASIO技术问询：如何在所有任务无进展时触发通知

ASIO本身没有原生的“空闲回调”机制，但可以通过以下两种可靠方式实现需求：

方法一：基于io_context::run()的循环封装 #

当io_context::run()返回时，说明当前没有可执行的就绪任务（若使用work_guard则会阻止run()退出，需按需处理）。我们可以利用这个特性，在run()退出后执行计算密集型任务，再投递空任务唤醒io_context继续运行：

#include <asio.hpp>

void run_cpu_intensive_task() {
    // 这里放置你的计算密集型逻辑
}

int main() {
    asio::io_context io_ctx;
    // work_guard用于阻止io_context在无任务时自动退出，按需启用
    auto work_guard = asio::make_work_guard(io_ctx);

    // 注册任务A、B、C
    io_ctx.post([]{ /* 任务A逻辑 */ });
    io_ctx.post([]{ /* 任务B逻辑 */ });
    io_ctx.post([]{ /* 任务C逻辑 */ });

    while (true) {
        // 运行io_context直到无就绪任务
        io_ctx.run();
        // 此时无任务可推进，执行计算密集型任务
        run_cpu_intensive_task();
        // 投递空任务唤醒io_context，等待下一批任务就绪
        io_ctx.post([]{});

        // 可在此添加退出条件，比如收到终止信号后重置work_guard
        // if (should_exit) { work_guard.reset(); break; }
    }

    return 0;
}

方法二：异步轮询检查空闲状态 #

通过周期性投递检查任务，判断当前是否有就绪任务，无任务时执行计算逻辑。这种方式无需打断io_context的持续运行，适合需要保持io_context一直活跃的场景：

基础轮询版 #

#include <asio.hpp>

void run_cpu_intensive_task() {
    // 计算密集型逻辑
}

void check_idle(asio::io_context& io_ctx) {
    // poll_one()会执行一个就绪任务（若存在），返回0表示无就绪任务
    if (io_ctx.poll_one() == 0) {
        run_cpu_intensive_task();
    }
    // 立即重新投递检查任务
    asio::post(io_ctx, [&io_ctx](){ check_idle(io_ctx); });
}

int main() {
    asio::io_context io_ctx;

    // 注册任务A、B、C
    io_ctx.post([]{ /* 任务A逻辑 */ });
    io_ctx.post([]{ /* 任务B逻辑 */ });
    io_ctx.post([]{ /* 任务C逻辑 */ });

    // 启动空闲检查
    check_idle(io_ctx);
    // 持续运行io_context
    io_ctx.run();

    return 0;
}

带延迟的轮询版（减少资源占用） #

如果担心频繁轮询消耗CPU，可以结合定时器添加检查间隔：

#include <asio.hpp>
#include <chrono>

void run_cpu_intensive_task() {
    // 计算密集型逻辑
}

void check_idle(asio::io_context& io_ctx, asio::steady_timer& timer) {
    if (io_ctx.poll_one() == 0) {
        run_cpu_intensive_task();
    }
    // 10ms后再次检查，可根据业务需求调整间隔
    timer.expires_after(std::chrono::milliseconds(10));
    timer.async_wait([&](std::error_code ec) {
        if (!ec) {
            check_idle(io_ctx, timer);
        }
    });
}

int main() {
    asio::io_context io_ctx;
    asio::steady_timer idle_check_timer(io_ctx);

    // 注册任务A、B、C
    io_ctx.post([]{ /* 任务A逻辑 */ });
    io_ctx.post([]{ /* 任务B逻辑 */ });
    io_ctx.post([]{ /* 任务C逻辑 */ });

    // 启动带延迟的空闲检查
    check_idle(io_ctx, idle_check_timer);
    io_ctx.run();

    return 0;
}

核心注意事项 #

• 避免阻塞IO线程：如果io_context运行在单线程中，长时间的计算任务会阻塞IO处理。建议将计算任务投递到独立的线程池执行，比如用asio::thread_pool：

  asio::thread_pool cpu_pool(4); // 4个计算线程
  void run_cpu_intensive_task() {
      asio::post(cpu_pool, []{
          // 计算密集型逻辑
      });
  }
  

• 控制循环退出：方法一中必须设置明确的退出条件（比如信号触发、业务结束标记），否则程序会无限循环执行空闲任务。
• 优先使用公开API：不要依赖ASIO内部的has_work()等非公开接口，避免版本兼容性问题，优先用run()返回值或poll_one()判断空闲状态。

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