扫二维码与项目经理沟通
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流
今天就跟大家聊聊有关Linux内核工作队列是什么,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。
创新互联建站是一家从事企业网站建设、成都网站制作、做网站、行业门户网站建设、网页设计制作的专业网站建设公司,拥有经验丰富的网站建设工程师和网页设计人员,具备各种规模与类型网站建设的实力,在网站建设领域树立了自己独特的设计风格。自公司成立以来曾独立设计制作的站点上1000家。
1、共享工作队列
1)、静态定义
宏:DECLARE_WORK(n, f)
,文件:include/linux/workqueue.h
,定义如下:
#define DECLARE_WORK(n, f) \ struct work_struct n = __WORK_INITIALIZER(n, f)
参数:
n:表示工作任务的名称;
f:表示工作任务的实现函数;
类似接口:DECLARE_DELAYED_WORK(n, f)
,创建延时工作任务。
2)、动态定义
文件:include/linux/workqueue.h
,定义如下:
#define INIT_WORK(_work, _func) \ __INIT_WORK((_work), (_func), 0)
参数:
_work
:表示工作任务的名称;
_func
:表示工作任务的实现函数;
2、自定义工作队列
文件:include/linux/workqueue.h
,定义如下:
#define create_workqueue(name) \ alloc_workqueue("%s", WQ_MEM_RECLAIM, 1, (name)) #define create_singlethread_workqueue(name) \ alloc_ordered_workqueue("%s", WQ_MEM_RECLAIM, name)
参数:
name:工作队列名称。传入值为字符串,和共享工作队列里的参数不同。
返回值:工作队列指针
工作任务定义 | 工作任务添加 | 工作任务清除 | 工作任务取消 |
---|---|---|---|
DECLARE_WORK() | schedule_work() | flush_work() | cancel_work_sync() |
DECLARE_DELAYED_WORK() | schedule_delayed_work() | flush_delayed_work() | cancel_delayed_work() cancel_delayed_work_sync() |
INIT_WORK() | schedule_work() | flush_work() | cancel_work_sync() |
INIT_DELAYED_WORK() | schedule_delayed_work() | flush_delayed_work() | cancel_delayed_work() cancel_delayed_work_sync() |
create_workqueue() | queue_work() queue_delayed_work() queue_work_on() | flush_workqueue() | destroy_workqueue() |
create_singlethread_workqueue() | queue_work() | flush_workqueue() | destroy_workqueue() |
注:
1、flush_work()
:堵塞工作任务,直到工作任务完成
2、flush_delayed_work()
:等待延时工作任务完成
3、cancel_work_sync()
:取消工作任务并等待它完成
4、cancel_delayed_work()
:取消延时工作任务
5、cancel_delayed_work_sync()
:取消延时工作任务并等待它完成
6、create_workqueue()
:对于多CPU系统,内核会在每个CPU上创建一个工作队列,使线程处理并行化
7、create_singlethread_workqueue()
:内核只在一个CPU上创建一个工作队列
8、queue_work_on()
:在指定CPU上添加工作任务,queue_work()
调用queue_work_on()
在所有CPU上添加工作任务
1、共享工作队列
文件:drivers/gpu/drm/drm_fb_helper.c
,举例如下:
## 3、工作任务的具体实现static void drm_fb_helper_restore_work_fn(struct work_struct *ignored){ ...}## 1、定义工作任务,名称:drm_fb_helper_restore_work,实现函数:drm_fb_helper_restore_work_fnstatic DECLARE_WORK(drm_fb_helper_restore_work, drm_fb_helper_restore_work_fn);static void drm_fb_helper_sysrq(int dummy1){ ## 2、将drm_fb_helper_restore_work加入到全局工作队列 schedule_work(&drm_fb_helper_restore_work);}
其它接口使用方法类似。
2、自定义工作队列
文件:drivers/input/touchscreen/gt9xx/gt9xx.c
## 1.定义工作任务和工作队列static struct delayed_work gtp_esd_check_work;static struct workqueue_struct * gtp_esd_check_workqueue = NULL;static int goodix_ts_init(void){ ... ## 2.初始化工作任务gtp_esd_check_work; 创建工作队列gtp_esd_check_workqueue INIT_DELAYED_WORK(>p_esd_check_work, gtp_esd_check_func); gtp_esd_check_workqueue = create_workqueue("gtp_esd_check"); ...}## 3.工作任务gtp_esd_check_work的实现函数static void gtp_esd_check_func(struct work_struct *work){ ...}void gtp_esd_switch(struct i2c_client *client, s32 on){ ... ## 4.将工作任务gtp_esd_check_work添加到工作队列gtp_esd_check_workqueue,延时调度 queue_delayed_work(gtp_esd_check_workqueue, >p_esd_check_work, ts->clk_tick_cnt); ... ## 5.等待延时任务完成 cancel_delayed_work_sync(>p_esd_check_work); ...}static int goodix_ts_remove(struct i2c_client *client){ ... ## 6.销毁工作队列gtp_esd_check_workqueue destroy_workqueue(gtp_esd_check_workqueue); ...}
注:工作队列允许任务重新调度和睡眠。
看完上述内容,你们对Linux内核工作队列是什么有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注创新互联行业资讯频道,感谢大家的支持。
我们在微信上24小时期待你的声音
解答本文疑问/技术咨询/运营咨询/技术建议/互联网交流