tasklet属于原子上下文延迟机制,但在驱动开发场景中,需休眠、耗时的延迟任务无法在该上下文执行,而工作队列(workqueue)正是为解决此类需求设计的机制,它让延迟任务能够在进程上下文异步执行,完美支撑长时间、需阻塞等待的复杂业务。
核心定位与本质
工作队列是内核广泛应用的异步工作延迟机制,其核心价值在于:任务运行在进程上下文,允许函数内部休眠、阻塞,从根源上突破了原子上下文的限制。相比tasklet等原子机制,它是唯一适配可休眠任务的延迟方案,尤其适合处理耗时IO、等待硬件资源等场景,能从根本上保障系统响应稳定性,避免中断上下文阻塞引发的系统卡顿。
核心数据结构:双核心构建机制基础
工作队列机制围绕工作项和工作队列两大核心数据结构展开,二者协同实现任务的定义与调度。
1. 工作项:待执行任务的载体
工作项是延迟任务的直接表达,内核提供两种类型,覆盖不同调度需求:
- 普通工作项(`structwork_struct`):提交后立即进入调度,由内核在系统资源允许时尽快执行,无额外延迟。
- 延迟工作项(`struct delayed_work`):内部封装了`struct work_struct`和定时器(`struct timer_list`),可指定最小等待时间,确保任务至少在指定时长后才被调度,满足周期性、延时执行的场景。
两类工作项可通过静态或动态方式初始化:
- 静态定义宏:`DECLARE_WORK(name, func)`用于定义普通工作项,`DECLARE_DELAYED_WORK(name, func)`用于定义延迟工作项,二者均为编译时初始化。
- 动态初始化函数:`INIT_WORK(work, func)`动态初始化普通工作项,`INIT_DELAYED_WORK(work, func)`动态初始化延迟工作项,适配运行时动态创建工作项的场景,灵活性更高。
工作项的处理函数遵循固定原型:`typedefvoid(*work_func_t)(struct work_struct *work);`,传入的参数为工作项本身。若为延迟工作项,可通过`to_delayed_work(work)`获取外层封装的`struct delayed_work`结构体,方便传递额外参数。
2. 工作队列:工作项的调度容器
工作队列(`struct workqueue_struct`)是工作项的承载容器,本质上是工作项的队列。与之配套的核心概念有两个:
- 工作线程:内核创建的专用线程,核心职责是从队列中取出工作项,逐一执行。
- 工作池:管理工作线程的集合,本质是线程池,负责统筹工作线程的调度与复用,提升资源利用率。
传统工作队列API(逐步废弃的旧方案)
传统工作队列API因设计局限已被标记废弃,目前仅作兼容保留,但仍需掌握其逻辑,以读懂历史代码。
1. 队列创建接口
- `create_workqueue(const char *name)`:为系统每个CPU创建专属工作线程,资源开销极大,在多核平台极易消耗大量内核线程资源,仅适配极少数特殊场景。
- `create_singlethread_workqueue(const char *name)`:全局仅创建一条工作线程,资源开销小,适配多数轻量场景,但并发处理能力有限。
2. 任务调度接口
- 普通任务调度:`queue_work(wq, work)`,将普通工作项提交到指定工作队列,成功返回`true`,若工作项已在队列中则返回`false`。
- 延迟任务调度:`queue_delayed_work(wq, dwork, delay)`,将延迟工作项提交到队列,延迟时间以jiffies为单位,可通过`msecs_to_jiffies()`、`usecs_to_jiffies()`将毫秒、微秒转换为jiffies,适配不同时间精度需求。
3. 任务管控与清理接口
- 任务取消:
- `cancel_work_sync(work)`:同步取消普通工作项,会等待正在执行的任务运行完成再返回,确保任务彻底结束后再清理,规避资源访问风险。
- `cancel_delayed_work(dwork)`:异步取消延迟工作项,仅移除定时器,若任务已启动运行则不会等待;若需确保任务彻底结束,需使用同步版本`cancel_delayed_work_sync(dwork)`。
- 队列刷新:`flush_workqueue(queue)`,等待指定队列中所有工作项执行完毕,常用于需要等待当前批次任务全部完成后再执行后续逻辑的场景。
- 队列销毁:`destroy_workqueue(queue)`,销毁已创建的工作队列,销毁前内核会自动等待队列中所有任务执行完成,保障任务安全收尾。
核心约束:所有带`_sync`后缀的函数均会阻塞休眠,只能在进程上下文调用,严禁在中断上下文、tasklet等原子上下文中使用。
内核共享队列:优先选择的默认方案
绝大多数驱动无需自建工作队列,内核预初始化的全局共享工作队列`system_wq`是首选,它由所有驱动共用线程池,既简化开发又节省资源。
1. 调度接口
内核为共享队列封装了便捷的调度接口,本质是对`queue_work`的二次封装,目标队列固定为`system_wq`:
- 普通任务调度:`schedule_work(work)`,立即调度普通工作项。
- 延迟任务调度:`schedule_delayed_work(dwork, delay)`,按指定延迟调度延迟工作项。
- 指定CPU调度:`schedule_work_on(cpu, work)`和`schedule_delayed_work_on(cpu, dwork, delay)`,可将任务指定调度到目标CPU执行,满足CPU亲和性需求。
2. 刷新接口与风险提示
- 配套刷新接口:`flush_scheduled_work()`,用于等待`system_wq`上所有任务执行完成。
- 核心风险:该接口会等待共享队列上的所有任务,包括其他驱动的任务,极易引发全局阻塞,大幅影响系统响应速度。开发中优先使用`cancel_work_sync()`精准等待自身任务,仅在极少数需要全局同步的场景才考虑使用共享队列刷新接口。
3. 核心选型原则
若无强隔离需求,优先使用内核共享队列;仅当任务需长期阻塞、需与其他驱动任务隔离、需自定义并发特性时,才考虑创建独立工作队列。
并发管理的工作队列(CMWQ):现代内核标准API
传统工作队列存在三大核心缺陷:大规模多核场景下`create_workqueue`会耗尽内核进程ID;独占线程模式并发调度开销大、上下文切换频繁;资源无法动态伸缩,难以适配不同场景的并发需求。因此内核推出并发管理的工作队列(CMWQ),成为当前内核的标准方案,旧API仅通过兼容层映射到新API维持可用。
1. 创建与销毁接口
- 普通并发队列:`alloc_workqueue(fmt,flags, max_active, args...)`,支持自定义并发能力,可按需求控制单CPU上的并行任务数量。
- 有序串行队列:`alloc_ordered_workqueue(fmt, flags, args...)`,队列采用FIFO串行执行策略,同一时刻仅运行一个任务,避免并发冲突,适配对执行顺序有严格要求的场景。
- 销毁接口:`destroy_workqueue(wq)`,销毁前自动等待队列内所有任务执行完毕,保障安全清理。
其中,`fmt`是队列名称格式化字符串,`max_active`控制单CPU并发上限,是管控队列负载的核心参数。
2. 核心标志位:适配不同场景的关键参数
`flags`是配置工作队列行为的核心,内核提供了多种标志位,精准适配各类业务场景:
- `WQ_UNBOUND`:工作线程不绑定固定CPU,调度器可根据负载均衡策略自由迁移任务,既适配CPU密集型长任务,又能避免绑定CPU导致的功耗升高,但会牺牲部分CPU缓存局部性优势。
- `WQ_MEM_RECLAIM`:为队列分配救援线程,专门保障内存回收路径的稳定性。内存紧张时常规内存分配会阻塞,若队列无此标志极易死锁,涉及内存回收、块设备驱动的场景必须设置该标志。
- `WQ_FREEZABLE`:适配电源管理场景,系统休眠时队列会被冻结,仅执行已入队任务,不再接收新任务,防止休眠镜像写入期间磁盘数据被修改,保障文件系统一致性;若任务需在休眠期间持续运行,禁止设置该标志。
- `WQ_HIGHPRI`:创建高优先级工作线程,调度优先级高于普通线程,适合低延迟需求的任务,且高优先级与普通优先级工作池相互隔离,互不干扰,但任务内部不宜长时间阻塞。
- `WQ_CPU_INTENSIVE`:标记任务为CPU密集型,这类任务不参与工作队列的并发管控,完全交由系统调度器调度,避免长时间占用CPU的任务阻塞其他普通任务,加密、数据压缩等CPU密集型业务普遍使用该标志。
3. 旧API与CMWQ的兼容映射
内核通过兼容性层实现旧API到新API的转换,确保历史代码正常运行:
- `create_workqueue(name)`映射为`alloc_workqueue(name, WQ_MEM_RECLAIM, 1)`,确保基础的内存回收安全性。
- `create_singlethread_workqueue(name)`映射为`alloc_ordered_workqueue(name, WQ_MEM_RECLAIM)`,天然适配串行执行需求。
- `create_freezable_workqueue(name)`映射为`alloc_workqueue(name, WQ_FREEZABLE | WQ_UNBOUND | WQ_MEM_RECLAIM, 1)`,覆盖冻结、负载均衡、内存回收三大核心需求。
其中,`alloc_ordered_workqueue`默认未绑定CPU,且`max_active`为1,天然实现串行有序执行。
关键调度补充与选型收尾
- 调度细节:`queue_work_on()`可将任务指定调度到目标CPU,任务优先在目标CPU执行;`queue_work()`优先在本地CPU调度,但不强制绑定;`schedule_work()`是`queue_work(system_wq, work)`的便捷封装,简化共享队列的使用。
- 选型分层准则:
1. 简短任务、无隔离需求:优先使用`schedule_work()`调度到共享队列,简化开发、节省资源。
2. 需串行执行、规避并发冲突:使用`alloc_ordered_workqueue()`创建有序队列,确保任务按顺序执行。
3. 需控制并发、资源隔离:通过`alloc_workqueue()`自定义并发上限,实现与其他任务的资源隔离。
4. 长任务、跨CPU负载均衡:搭配`WQ_UNBOUND`标志,让调度器自由调度,实现负载均衡。
5. 涉及内存回收、块设备驱动:必须添加`WQ_MEM_RECLAIM`,保障内存压力下的稳定性。
6. 电源休眠需冻结任务:搭配`WQ_FREEZABLE`,保障休眠镜像的一致性。
工作队列是内核中断下半部可休眠任务的核心支撑机制,其灵活的选型策略与丰富的标志位,能精准适配各类驱动开发场景,是内核驱动开发的关键知识。后续内容将衔接Linux内核中断管理,系统梳理中断上下半部的整体框架,完成中断处理机制的知识闭环。