boost::asio中strand结合thread_group仅用首个线程的问题排查

我之前在使用Boost 1.66的strand时也碰到过类似的情况，结合你的环境和问题描述，给你几个具体的排查和解决方向：

1. 确保所有线程都启动了IO上下文的事件循环 #

这是最常见的问题：如果你的thread_group里只有第一个线程调用了io_context::run()，那其他线程自然会闲置。你需要保证每个线程的入口函数都执行io_context.run()（或者run_one()/poll()这类事件循环方法）。

比如错误的写法：

// 第二个线程没调用io_context.run()，直接闲置
threads.create_thread([&io_context](){ io_context.run(); });
threads.create_thread([](){ /* 空函数 */ });

正确的写法应该是每个线程都绑定io_context的run方法：

threads.create_thread([&io_context](){
    std::cout << "Thread " << boost::this_thread::get_id() << " started\n";
    io_context.run();
});
threads.create_thread([&io_context](){
    std::cout << "Thread " << boost::this_thread::get_id() << " started\n";
    io_context.run();
});

2. 使用Work Guard防止IO上下文提前退出 #

Boost.Asio的io_context::run()会在没有待处理任务时立即返回。如果你的任务执行速度很快，第一个线程可能在第二个线程完成初始化前就把所有任务处理完了，导致第二个线程刚启动就退出。

解决办法是添加一个work guard，让io_context保持运行状态直到你手动停止它：

// Boost 1.66可以用这个方式创建work guard
auto work = boost::asio::make_work_guard(io_context);

当你所有任务都执行完毕后，调用work.reset()就能允许io_context的run()方法返回，线程可以正常退出。

3. 确保任务通过Strand提交且有足够执行时间 #

首先确认你是通过strand的post()或dispatch()方法提交任务，而不是直接提交给io_context（直接提交的任务会被任意线程并行执行，不符合strand的串行要求）：

// 正确：通过strand提交任务，保证串行执行
strand.post([](){ /* 你的任务逻辑 */ });

// 错误：直接提交给io_context，无法利用strand的串行调度
io_context.post([](){ /* 你的任务逻辑 */ });

另外，如果你的任务执行时间极短（比如只是打印一行日志），第一个线程会瞬间处理完所有任务，第二个线程根本没机会抢到任务。可以给任务加一点模拟延迟，验证多线程调度：

strand.post([i](){
    std::cout << "Task " << i << " running on thread " << boost::this_thread::get_id() << "\n";
    // 模拟任务执行时间，让其他线程有机会参与调度
    std::this_thread::sleep_for(std::chrono::milliseconds(50));
});

4. 检查编译和Boost库的多线程配置 #

• 编译选项：确保编译时添加了-pthread链接选项，Boost.Asio的多线程依赖POSIX线程库，没有这个选项可能导致多线程功能异常。
• Boost库版本：确认你编译的Boost确实是多线程版本。编译Boost时需要指定threading=multi参数（比如./b2 threading=multi --build-type=complete）。如果误编译了单线程版本，即使代码里用了thread_group，也无法实现多线程调度。

完整可运行示例 #

这里给你一个经过验证的示例代码，在Debian 9 + Boost 1.66环境下可以让两个线程交替处理strand任务：

#include <boost/asio.hpp>
#include <boost/thread.hpp>
#include <iostream>
#include <chrono>

int main() {
    boost::asio::io_context io_context;
    auto strand = boost::asio::make_strand(io_context.get_executor());
    auto work = boost::asio::make_work_guard(io_context);

    boost::thread_group threads;
    threads.create_thread([&io_context](){
        std::cout << "Thread ID: " << boost::this_thread::get_id() << " started\n";
        io_context.run();
        std::cout << "Thread ID: " << boost::this_thread::get_id() << " exited\n";
    });
    threads.create_thread([&io_context](){
        std::cout << "Thread ID: " << boost::this_thread::get_id() << " started\n";
        io_context.run();
        std::cout << "Thread ID: " << boost::this_thread::get_id() << " exited\n";
    });

    // 提交10个串行任务
    for(int i = 0; i < 10; ++i) {
        strand.post([i](){
            std::cout << "Task " << i << " executed on thread: " << boost::this_thread::get_id() << "\n";
            std::this_thread::sleep_for(std::chrono::milliseconds(50));
        });
    }

    // 等待所有任务完成后停止io_context
    std::this_thread::sleep_for(std::chrono::seconds(1));
    work.reset();
    threads.join_all();

    return 0;
}

编译命令：

g++ -std=c++11 your_file.cpp -o strand_test -lboost_system -lboost_thread -pthread

运行这个程序，你应该能看到任务交替在两个线程上执行。

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