没有合适的资源?快使用搜索试试~ 我知道了~
周末看了nginx线程池部分的代码,顺手照抄了一遍,写成了自己的版本。实现上某些地方还是有差异的,不过基本结构全部摘抄。 在这里分享一下。如果你看懂了我的版本,也就证明你看懂了nginx的线程池。 本文只列出了关键数据结构和API,重在理解nginx线程池设计思路。完整代码在最后的链接里。 1.任务节点 typedef void (*CB_FUN)(void *); //任务结构体 typedef struct task { void *argv; //任务函数的参数(任务执行结束前,要保证参数地址有效) CB_FUN handler; //任务函数(返回值必
资源推荐
资源详情
资源评论
nginx线程池源码分析线程池源码分析
周末看了nginx线程池部分的代码,顺手照抄了一遍,写成了自己的版本。实现上某些地方还是有差异的,不过基本结构全部
摘抄。
在这里分享一下。如果你看懂了我的版本,也就证明你看懂了nginx的线程池。
本文只列出了关键数据结构和API,重在理解nginx线程池设计思路。完整代码在最后的链接里。
1.任务节点任务节点
typedef void (*CB_FUN)(void *);
//任务结构体
typedef struct task
{
void *argv; //任务函数的参数(任务执行结束前,要保证参数地址有效)
CB_FUN handler; //任务函数(返回值必须为0 非0值用作增加线程,和销毁线程池)
struct task *next; //任务链指针
}zoey_task_t;
handler为函数指针,是实际的任务函数,argv为该函数的参数,next指向下一个任务。
2.任务队列任务队列
typedef struct task_queue
{
zoey_task_t *head; //队列头
zoey_task_t **tail; //队列尾
unsigned int maxtasknum; //最大任务限制
unsigned int curtasknum; //当前任务数
}zoey_task_queue_t;
head为任务队列头指针,tail为任务队列尾指针,maxtasknum为队列最大任务数限制,curtasknum为队列当前任务数。
3.线程池线程池
typedef struct threadpool
{
pthread_mutex_t mutex; //互斥锁
pthread_cond_t cond; //条件锁
zoey_task_queue_t tasks;//任务队列
unsigned int threadnum; //线程数
unsigned int thread_stack_size; //线程堆栈大小
}zoey_threadpool_t;
mutex为互斥锁 cond为条件锁。mutex和cond共同保证线程池任务的互斥领取或者添加。
tasks指向任务队列。
threadnum为线程池的线程数
thread_stack_size为线程堆栈大小
4.启动配置启动配置
//配置参数
typedef struct threadpool_conf
{
unsigned int threadnum; //线程数
unsigned int thread_stack_size;//线程堆栈大小
unsigned int maxtasknum;//最大任务限制
}zoey_threadpool_conf_t;
启动配置结构体是初始化线程池时的一些参数。
5.初始化线程池初始化线程池
首先检查参数是否合法,然后初始化mutex,cond,key(pthread_key_t)。key用来读写线程全局变量,此全局变量控
资源评论
weixin_38663151
- 粉丝: 3
- 资源: 897
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功