Boost Asio：停止上下文与接收器后timer_thread_function陷入等待

问题 #

基于Boost官网的advanced_server.cpp示例搭建Web服务器，期望实现启动、处理请求、停止后无需终止进程即可重新监听不同套接字的功能。多数情况下流程正常，但偶尔在停止阶段调用std::thread::join()等待io_context线程时卡住，此时有线程卡在win_iocp_io_context.ipp的timer等待代码处：

struct win_iocp_io_context::timer_thread_function
{
  void operator()()
  {
    while (::InterlockedExchangeAdd(&io_context_->shutdown_, 0) == 0)
    {
      if (::WaitForSingleObject(io_context_->waitable_timer_.handle,
            INFINITE) == WAIT_OBJECT_0) // 此处无限卡住
      {
        ::InterlockedExchange(&io_context_->dispatch_required_, 1);
        ::PostQueuedCompletionStatus(io_context_->iocp_.handle,
            0, wake_for_dispatch, 0);
      }
    }

    win_iocp_io_context* io_context_;
};

当前的停止流程如下：

// Acceptor close
_acceptor.cancel();
_acceptor.close();
_acceptor.release();

{
    // 等待acceptor的async_accept处理器获取取消error_code
    std::unique_lock<std::mutex> lock(_mutex);
    _cvShutdown.wait_for(lock, std::chrono::milliseconds(1000), [this]() { return _shutdownComplete;    });
}

// Socket close
_socket.shutdown(tcp::socket::shutdown_send, errorCode);
_socket.cancel();
_socket.close();

// 关闭io_context
_ioContext.stop();

for (const auto& upThread : _httpThreadPool)
{
    if (upThread->joinable())
    {
        upThread->join();
    }
}

我认为cancel()调用应包含在close()中，但已做了全面处理。_httpThreadPool是一组仅调用_iocontext.run()的std::thread。请问停止流程是否遗漏了步骤？如何确保timer_thread_function正常关闭，避免在已停止的io_context上无限等待句柄？

使用环境：Boost 1.78.0，Visual C++ 14.33.31629、Windows SDK 10.0.22000、MSBuild 17.5.0。

解决方案 #

1. 手动唤醒IOCP端口，打破timer线程的无限等待 #

卡死的核心原因是：io_context.stop()设置了shutdown_标志，但timer线程卡在WaitForSingleObject的无限等待中，无法循环检测标志变化。需要主动向IOCP端口发送信号，让等待返回。

添加以下代码在_ioContext.stop()之后：

// 强制唤醒IOCP端口，让timer线程退出等待
::PostQueuedCompletionStatus(
    static_cast<HANDLE>(_ioContext.impl()->get_iocp_handle()),
    0,
    win_iocp_io_context::wake_for_dispatch,
    nullptr
);

这会触发WaitForSingleObject返回，timer线程会重新检查shutdown_标志，发现已置位后退出循环。

2. 调整停止流程的顺序 #

当前流程先清理套接字再停止io_context，容易导致异步操作残留。建议改为：

• 先停止io_context，阻止新的异步任务
• 唤醒IOCP端口后等待线程退出
• 最后清理套接字资源
• 重置io_context为下次启动做准备

修改后的停止流程示例：

// 1. 停止io_context，拒绝新的异步操作
_ioContext.stop();

// 2. 唤醒IOCP端口，确保timer线程退出等待
::PostQueuedCompletionStatus(
    static_cast<HANDLE>(_ioContext.impl()->get_iocp_handle()),
    0,
    win_iocp_io_context::wake_for_dispatch,
    nullptr
);

// 3. 等待所有线程退出
for (auto& upThread : _httpThreadPool)
{
    if (upThread->joinable())
    {
        upThread->join();
    }
}

// 4. 清理套接字资源
_acceptor.cancel();
_acceptor.close();

_socket.shutdown(tcp::socket::shutdown_send, errorCode);
_socket.cancel();
_socket.close();

// 5. 重置io_context，为下次启动做准备
_ioContext.restart();

3. 移除_acceptor.release()调用 #

release()会将底层套接字句柄的所有权转移给调用者，而Boost内部可能仍持有该句柄的引用，导致状态不一致。直接用close()即可完成资源清理。

4. 清理所有未完成的定时器任务 #

如果服务器使用了boost::asio::steady_timer等定时器，停止前必须调用timer.cancel()取消所有未完成的异步定时器操作，否则这些任务会阻止io_context正常停止。

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