如何将任务分配给boost::asio::thread_pool指定线程？任务能否串行？

1. 让任务始终分配到线程池的同一个线程 #

boost::asio::thread_pool本质是多线程运行的io_context，默认任务会被调度到任意空闲线程。如果要严格让指定任务始终在同一个线程执行，需要将这些任务绑定到单线程执行上下文，实现方式如下：

#include <boost/asio.hpp>
#include <vector>

struct Task {
    int a = 0;
    int b = 0;
    void run1() { /* 任务逻辑 */ }
    void run2() { /* 任务逻辑 */ }
};

int main() {
    std::vector<Task> tasks(100000);
    boost::asio::thread_pool pool(10);

    // 创建独立的io_context，用于承载固定线程的任务
    boost::asio::io_context single_thread_ctx;
    // 将该io_context的运行循环提交到线程池，占用一个线程
    boost::asio::post(pool, [&single_thread_ctx]() {
        single_thread_ctx.run();
    });

    // 所有目标任务提交到这个单线程io_context，确保始终在同一个线程执行
    for (auto& task : tasks) {
        boost::asio::post(single_thread_ctx, [&task]() {
            task.run1();
            task.run2();
        });
    }

    // 任务提交完成后停止io_context，等待线程退出
    single_thread_ctx.stop();
    pool.join();
    return 0;
}

这种方式下，所有提交到single_thread_ctx的任务都会在执行single_thread_ctx.run()的那个线程中运行，完全满足“始终分配到同一个线程”的需求。

2. 让任务串行执行 #

如果只需要任务串行执行（不严格绑定到同一线程），使用boost::asio::strand即可，它会自动将任务排队，保证按提交顺序依次执行：

#include <boost/asio.hpp>
#include <vector>

struct Task {
    int a = 0;
    int b = 0;
    void run1() { /* 任务逻辑 */ }
    void run2() { /* 任务逻辑 */ }
};

int main() {
    std::vector<Task> tasks(100000);
    boost::asio::thread_pool pool(10);

    // 创建strand绑定到线程池的执行器
    boost::asio::strand<boost::asio::thread_pool::executor_type> strand(pool.get_executor());

    // 通过strand提交任务，保证串行执行
    for (auto& task : tasks) {
        boost::asio::post(strand, [&task]() {
            task.run1();
            task.run2();
        });
    }

    pool.join();
    return 0;
}

注意：strand仅保证任务串行执行，任务可能被调度到线程池的不同空闲线程，但同一时间只会有一个任务在执行。如果既要串行又要固定线程，直接使用第一种单线程io_context的方案即可——单线程上下文本身就会串行执行所有任务。

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