创建和销毁线程调度线程

其主要针对服务器端多线程场景下服务器频繁接收请求每个请求都分配一个单独的线程去处理。

创建和销毁线程调度线程

线程池主要解决的核心问题是资源管理的问题。

在并发环境下系统不能确定在任意时刻中有多少任务需要处理有多少资源需要投入这种不确定性带来以下问题

频繁申请/销毁/调度资源将带来执行业务之外的开销线程数量过多时这部分消耗非常巨大对资源申请缺少抑制手段容易引发资源耗尽的风险系统无法合理的管理内部资源的分布会降低系统的稳定性

线程池管理器

用于初始化一定数量的线程资源提供启动线程停止线程、调配任务的方法。

工作线程

线程池空闲

主程序添加的任务数量大于当前线程池的中线程数量且任务缓冲队列已满

头文件

TaskPriority{Level0,Level1,Level2};typedef

std::functionvoid()

ThreadPool{public:ThreadPool();virtual

~ThreadPool();void

taskPair);private:ThreadPool(const

ThreadPool);

m_mutex;std::condition_variable

m_cond;bool

m_bIsStarted(false){}ThreadPool::~ThreadPool(){if

(!m_threads.empty()){return;}m_bIsStarted

true;m_threads.reserve(kiInitThreadSize);for

(int

std::thread(std::bind(ThreadPool::ThreadLoop,

this)));}}void

std::endl;{std::unique_lockstd::mutex

(auto

task){std::unique_lockstd::mutex

taskPair(Level2,

task);m_tasks.push(taskPair);m_cond.notify_one();}void

TaskPair

taskPair){std::unique_lockstd::mutex

lock(m_mutex);m_tasks.push(taskPair);m_cond.notify_one();}void

ThreadPool::ThreadLoop(){std::cout

tid

(oneTask){oneTask();}}std::cout

tid

std::endl;m_cond.wait(lock);}std::cout

ThreadPool::Take

m_tasks.top().second;m_tasks.pop();}return

taskTmp;}}