linux 程序线程池逻辑,linux C 线程池的 实现 基本结构体逻辑
发布时间：2022-12-08 11:28:32 所属栏目：Linux 来源：
导读： // 描述线程池相关信息
struct threadpool_t {
pthread_mutex_t lock; // 用于锁住本结构体
pthread_mutex_t thread_counter; // 记录忙碌状态线程个数的锁
pthread_cond_t que
struct threadpool_t {
pthread_mutex_t lock; // 用于锁住本结构体
pthread_mutex_t thread_counter; // 记录忙碌状态线程个数的锁
pthread_cond_t que
|
// 描述线程池相关信息 struct threadpool_t { pthread_mutex_t lock; // 用于锁住本结构体 pthread_mutex_t thread_counter; // 记录忙碌状态线程个数的锁 pthread_cond_t queue_not_full; // 当任务队列满时, 添加任务的线程阻塞，等待条件变量 pthread_cond_t queue_not_empty; // 任务队列里不为空时，通知等待任务的线程 pthread_t *threads; // 存放线程池中每个线程的tip，数组 pthread_t adjust_tid; // 存放管理线程的tid threadpool_task_t* task_queue; // 任务队列 int min_thr_num; // 线程池最小线程数 int max_thr_num; // 线程池最大线程数 int live_thr_num; // 当前存活线程个数 int busy_thr_num; // 忙状态线程个数 int wait_exit_thr_num; // 要销毁的线程个数 int queue_front; // 任务队列对头下标 int queue_rear; // 任务队列队尾下标 int queue_size; // 任务队列中的任务数 int queue_max_size; // 任务队列中可容纳的任务上限 int shutdown; // 标志位，线程池使用的状态 true/false }; 线程池是一个结构体， 结构体中封装了四个用于线程同步的锁。一个用于锁住整个结构体，一个用来锁住忙碌线程的数量 一个条件变量，当任务队列满的时候，添加线程阻塞 一个条件变量，当队列不为空时，通知等待任务的线程 其中结构体中存放线程tid的数组，有一个管理线程的的线程tid 有一个任务队列。 有一个存放最小线程数(初始状态的线程数的线程) 存放最大线程数(线程的最大数量) 一个变量表示现在存活的线程数线程池linux，一个变量表示忙碌状态的线程数。 一个变量表示要销毁的线程数。 对于任务队列，封装了队列的队头，队尾， 队列的长度和最大容量 每一个队列中的元素是一个函数指针, 作为回调函数 // 任务结构体 typedef struct { void* (*fundction)(void*); // 函数指针, 回调函数 void* arg; // 上面函数的参数 }threadpool_task_t; 再用一个变量表示队列是否关闭。 （编辑：财气旺网 - 财气网） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |
站长推荐