Skip to content

YMhao/threadPool

Repository files navigation

概述

这是线程池的一种实现

工作线程

为了更好的描述,,我把线程池里的线程称为工作线程。 每个工作线程都拥有自己的任务队列和锁。

线程池任务分配原则

1、优先分配:新任务优先分配给空闲的工作线程,如果全部工作线程都忙,优先分配任务队列比较短的工作线程。 2、任务再分配:当存在空闲线程时,超过阀值时, 当前工作线程就会把超过阀值的任务重新分配出去。

使用说明

如果在windows用这个库,要安装pthread库, gcc库(原子操作), linux可以直接用

线程池类:class ThreadPool 任务基类:class Task

接口说明

1、 ThreadPool::Init(uint32_t worker_size) 初始化线程池的工作线程的数量

2、ThreadPool::SetThresholdRedistribution(uint32_t threshold) 设置任务重新分配的阈值,根据需要设置,当存在空闲线程时,超过阀值时, 当前工作线程就会把超过阀值的任务重新分派出去

3、ThreadPool::AddTask(Task* pTask); 添加任务到线程池

4、ThreadPool::SetMaxTaskCount(uint32_t task_count) 设置最大任务数,任务完成后,打印总耗时和tps,并强行退出进程, 该类接口只用于线程池性能测试,生产环境勿用该接口

如何衡量一个线程池的性能

测试大量消耗时长不同的 Task。

测试demo

请查看 demo.cpp(比较粗略的估算在一定计算量的task的线程池性能)

About

高性能线程池的一种实现

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Contributors 2

  •  
  •