细版注释

可以先参考精简版的注释尝试写一写代码感觉有难度的话就参考详细版。

精简版注释

1.通过mutex互斥对pop、push操作加锁从而实现“安全”

2.内部封装的queuequeue容器内部存储share_ptr数据通过share_ptr间接存储好处:

将每个数据的share_ptr初始化放在push()中wait_and_pop就算异常安全的

对share_ptr实例分配内存的操作可以脱离锁的保护有利于增强性能

//成员函数

两种poptry_pop立即返回即使队列为空通过返回值表示操作失败

wait_and_pop

thread_pool():将监控异常的原子变量设置为false

2.析构函数

将原子变量设置为true避免线程池销毁后工作线程还在循环申请任务

3.提交线程函数函数模板

1.通过mutex互斥对pop、push操作加锁从而实现“安全”

2.内部封装的queuequeue容器内部存储share_ptr数据通过share_ptr间接存储好处:

将每个数据的share_ptr初始化放在push()中wait_and_pop就算异常安全的

对share_ptr实例分配内存的操作可以脱离锁的保护有利于增强性能

//成员函数

//通过move移动操作降低开销2.互斥上锁3.队列push数据4.条件变量通知有数据}

3.pop

//pop操作都是要操作队列的所以一开始就要上锁没有操作能提取到互斥之外1.互斥上锁2.判断是否为空队列

if(空)

//通过move移动操作降低开销2.队列pop3.return

true;}}

//pop操作都是要操作队列的所以一开始就要上锁没有操作能提取到互斥之外1.互斥上锁2.通过条件变量等待条件发生通过lambda表达式保证即使被条件变量唤醒了也要保证队列非空才能进行pop操作3.对头数据传给value;4.队列pop

4.通过返回值传递要pop的数据:std::shared_ptrT

try_pop(){

//pop操作都是要操作队列的所以一开始就要上锁没有操作能提取到互斥之外1.互斥上锁2.判断是否为空队列

if空

nullptr;else(不空){1.临时变量取得队头数据2.队列pop3.return

wait_and_pop(){

//pop操作都是要操作队列的所以一开始就要上锁没有操作能提取到互斥之外1.互斥上锁2.通过条件等待条件发生通过lambda表达式保证即使被条件变量唤醒了也要保证队列非空才能进行pop操作3.临时变量取得对头数据4.队列pop5.return

临时变量}

//最简单的线程池::工作线程数目固定当有任务要处理时就把他放进任务队列

//所以需要一个任务队列用threadsafe_queue来实现

//各线程从任务队列中领取任务

//工作线程存储在vector容器中并被引用到join_threads中进行统一的析构管理

//私有成员

thread_pool():将监控异常的原子变量设置为false

通过std::thread::hardware_concurrency()取得最大线程数

try

将原子变量设置为true避免线程池销毁后工作线程还在循环申请任务

3.提交线程函数函数模板

还需要封装thread类使std::thread对象在所有路径皆不可联结详细请参考本书第八章或effective

modren

_THREADRAII_H_//通过封装thread类使std::thread对象在所有路径皆不可联结

详细参见

{private:std::vectorstd::thread

join_threads(std::vectorstd::thread

long

i){if(threads[i].joinable()){threads[i].join();}else{threads[i].detach();}}}

#endif