首先要明确一点：boost::asio::thread_pool::stop()的设计本来就不是用来终止正在运行的任务的——它只是告诉线程池不要再接受新的任务，然后等待所有已经提交并正在执行的任务完成后，再让线程池的线程退出。所以你看到所有任务都执行完是完全符合预期的。

要实现任务可取消，目前安全的方式都是协作式取消：让任务在执行过程中定期检查一个"取消信号"，如果检测到取消，就主动退出执行流程。强制中断线程（比如用系统级的线程终止API）会带来很多风险（资源泄漏、死锁、数据结构损坏），不推荐使用。

下面给你几种可行的实现方案，从简单通用到原生适配Boost.Asio的都有：

方案1：用原子变量实现通用取消标记 #

这是最直接、不依赖额外库特性的方式，适合任何多线程场景：

#include <atomic>
#include <boost/asio/thread_pool.hpp>
#include <boost/thread/thread.hpp>

class CancelableTask {
public:
    std::atomic<bool> is_canceled_{false};

    virtual void operator()() {
        std::cout << "Task started " << std::endl;
        DoSomeWork();
        std::cout << "Task in progress" << std::endl;

        for (int i = 0; i < 15; ++i) {
            // 每次循环前检查取消标记
            if (is_canceled_.load(std::memory_order_relaxed)) {
                std::cout << "Task canceled at iteration " << i << std::endl;
                return; // 主动退出任务
            }
            boost::this_thread::sleep_for(boost::chrono::milliseconds(1000));
        }

        std::cout << "Task ended" << std::endl;
    }

private:
    void DoSomeWork() {} // 你的实际工作逻辑
};

using TaskPtr = std::shared_ptr<CancelableTask>;

void Test_CreateAndCancel(std::vector<TaskPtr> &tasks) {
    boost::asio::thread_pool thread_pool(4);

    // 提交所有任务到线程池
    for (auto task : tasks) {
        boost::asio::post(thread_pool, [task] { (*task)(); });
    }

    // 模拟取消操作：设置所有任务的取消标记
    for (auto task : tasks) {
        task->is_canceled_.store(true, std::memory_order_relaxed);
    }

    thread_pool.stop(); // 停止接受新任务
    thread_pool.join(); // 必须等待所有线程完成，避免主线程提前退出
}

关键点：

• 用std::atomic<bool>确保取消标记在多线程间的可见性，避免编译器优化导致任务看不到最新的取消状态。
• 把长时间阻塞的操作（比如你的1秒sleep）拆分成可中断的小段，这样取消信号能被及时响应——如果你的实际工作是阻塞更长时间的IO操作，可能需要用异步IO配合取消机制。

方案2：用Boost.Asio原生的取消机制 #

如果你想和Boost.Asio的生态更好地结合，可以用cancellation_signal和cancellation_slot，它可以批量触发多个任务的取消信号，不需要逐个设置标记：

#include <boost/asio/cancellation_signal.hpp>
#include <boost/asio/cancellation_slot.hpp>
#include <boost/asio/thread_pool.hpp>
#include <boost/thread/thread.hpp>

class CancelableTask {
public:
    explicit CancelableTask(boost::asio::cancellation_slot cancel_slot) 
        : cancel_slot_(std::move(cancel_slot)) {
        // 注册取消回调：当收到取消信号时，设置内部的取消标记
        cancel_slot_.assign([this] {
            is_canceled_.store(true, std::memory_order_relaxed);
        });
    }

    virtual void operator()() {
        std::cout << "Task started " << std::endl;
        DoSomeWork();
        std::cout << "Task in progress" << std::endl;

        for (int i = 0; i < 15; ++i) {
            if (is_canceled_.load(std::memory_order_relaxed)) {
                std::cout << "Task canceled at iteration " << i << std::endl;
                return;
            }
            boost::this_thread::sleep_for(boost::chrono::milliseconds(1000));
        }

        std::cout << "Task ended" << std::endl;
    }

private:
    boost::asio::cancellation_slot cancel_slot_;
    std::atomic<bool> is_canceled_{false};
    void DoSomeWork() {}
};

using TaskPtr = std::shared_ptr<CancelableTask>;

void Test_CreateAndCancel(std::vector<TaskPtr> &tasks) {
    boost::asio::thread_pool thread_pool(4);
    boost::asio::cancellation_signal cancel_signal;

    // 为每个任务绑定同一个取消信号的slot
    for (auto& task : tasks) {
        task = std::make_shared<CancelableTask>(cancel_signal.slot());
        boost::asio::post(thread_pool, [task] { (*task)(); });
    }

    // 模拟取消操作：广播取消信号给所有绑定的任务
    cancel_signal.emit(boost::asio::cancellation_type::all);

    thread_pool.stop();
    thread_pool.join();
}

关键点：

• cancellation_signal可以一次性触发所有绑定它的cancellation_slot的回调，适合批量管理多个任务的取消。
• 如果你的任务里用到了Boost.Asio的异步操作（比如async_read、async_write），可以直接让这些异步操作响应取消信号，不需要手动检查标记——asio会自动终止异步操作并返回错误码boost::asio::error::operation_aborted。

额外注意事项 #

1. 必须调用thread_pool::join()：你的测试代码里没有这一步，虽然看起来任务执行完了，但那是因为主线程退出前刚好任务完成。实际场景中，如果主线程在任务完成前退出，会导致线程池的线程被强制终止，可能引发未定义行为。
2. 协作式取消的必要性：不要尝试用std::thread::terminate或者系统级的线程中断API（比如Windows的TerminateThread），这些操作会直接杀死线程，导致线程持有的锁无法释放、内存泄漏、数据结构损坏等严重问题。
3. 优化取消响应速度：如果你的任务中有长时间阻塞的操作（比如等待IO、大型计算），要尽量把这些操作拆分成可中断的小块，让取消标记的检查更频繁，这样任务能更快响应取消信号。

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