线程池如何实现线程复用？基于Object Pool Manager模式的线程池作业疑问

你对作业要求的理解没有偏差，你认为“线程不可复用”的认知本质是对操作系统原生线程生命周期的片面理解，和线程池的池化设计并不冲突。

线程复用的实现原理 #

操作系统原生线程的入口函数执行完毕后确实会自动退出，线程池的复用逻辑本质就是不让线程的入口函数执行完，靠驻留循环承接不同任务：

• 每个池内的原生线程启动后，会进入无限循环逻辑，优先从线程池的共享任务队列中取待执行任务，队列空时就进入阻塞等待状态，不会退出
• 拿到任务后执行任务的业务逻辑，执行完毕后不会结束线程，而是回到循环逻辑继续等待新的任务
• 只有收到线程池的销毁指令时，线程才会跳出循环，正常结束生命周期

作业中“所有权转移/交还”逻辑的适配 #

作业要求的对象池模式接口设计，和线程复用逻辑完全兼容，不需要让原生线程真的重复创建、销毁：

• 你暴露给调用方的“线程实例”本质是线程句柄的包装类，并不是操作系统原生线程本身
• 调用方拿到包装类后，相当于获得了对应池内原生线程的使用权，可以提交自定义任务让该线程执行
• 调用方交还线程的操作，本质是通知线程池：当前包装类绑定的原生线程已经完成当前任务，可以重新分配给其他调用方使用
• 全程原生线程始终处于驻留状态，只是在「已分配-执行任务-空闲待分配」的状态之间流转，也就是所谓的复用
• 当池内所有线程都处于已分配状态时，新的调用请求会进入等待队列，直到有线程被交还回池为止

简单实现伪代码参考 #

// 池内工作线程的入口函数
void WorkerThread::entry() {
    while (!thread_pool->is_stopped) {
        std::function<void()> user_task;
        // 等待任务或者停止信号
        {
            std::unique_lock<std::mutex> lock(thread_pool->mtx);
            thread_pool->cv.wait(lock, [this] {
                return thread_pool->is_stopped || !thread_pool->task_queue.empty();
            });
            if (thread_pool->is_stopped) break;
            user_task = std::move(thread_pool->task_queue.front());
            thread_pool->task_queue.pop();
        }
        // 执行调用方提交的任务
        user_task();
    }
}

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