蜗窝科技

@heziq：如果CMWQ的代码让你眼花缭乱，那么不如先看看旧workqueue上的并发。 1、挂入队列。对于旧的workqueue而言，有两种场景： （1）single thread workqueue （2）multi thread workqueue或者说per cpu thread workqueue 无论哪一种场景，当调用queue_work的时候，cpu已经选定。对于single thread workqueue，选择singlethread_cpu定义的那个cpu（一般是first possible cpu），对于per cpu thread workqueue，选择当前的cpu，也就是说，哪个cpu上执行queue_work，就挂入哪一个cpu对应的cpu_workqueue_struct。对于WORK_STRUCT_PENDING标记，你可以再看看queue_work的代码，代码中，test_and_set_bit是原子操作，因此，只能有一个thread进入queue work区域，也就是说，无论有多少个thread（可能来自多个cpu上的多种上下文）调用queue_work，结果只有一个work挂入某个cpu上的work list，变成pending状态。这里还有一个小的同步细节：wq_per_cpu访问了per cpu变量，而get_cpu/put_cpu分别disable preempt和enable preempt，确保了在访问Per-CPU变量的时候，current thread不能调度到其他CPU上去。 需要注意的是，WORK_STRUCT_PENDING可以保证pending状态的work只有一个，但是，如果一旦该work进入执行状态会怎样呢？ 2、执行work。在worker thread中，处理work的大概流程是： （1）从该worker thread对应的work list中摘下一个work （2）clear pending flag （3）执行该work的callback function 如果该work进入执行状态，pending flag已经清除，因此后续queue_work可以继续将work挂入worker list。对于single thread workqueue，由于只有一个worklist，只有一个thread，虽然该thread可以被调度到多个cpu上执行，但是不可能有多个thread同时执行，因此，对于single thread workqueue，其work（不论是否是同一个work）的callback function都是不会重入的，也就是说，各个work都是严格串行化执行。对于per cpu workqueue，各个online的cpu上都有一个worker thread及其要处理的work list。因此，有可能会有多个work在多个cpu上执行。我们举一个实际的例子：假设有一个per cpu workqueue，我们称之WQ，有work A和work B可能来自driver A和driver B，Driver A和Driver B的中断触发并分别送达cpu 0和cpu1，在驱动的handler中会queue相应的work到WQ去，因此work A和work B分别在cpu 0和cpu 1上的worker thread中执行，因此work A和work B的callback function是完全并发的。如果Driver A和Driver B的中断触发并都送达了cpu 0，那么work A和work B的callback function在cpu0上worker thread是串行执行的。上面讨论了多个work实例的并发，那么指定的work，例如work A的并发是怎样的呢？其实也是类似的，如果driver A的中断始终送达cpu 0，那么work A的callback是串行执行的，如果driver A的中断可以送达多个cpu ，那么在多个cpu上，work A的callback也是可以并发执行的。 最后总结一下：挂入到multi thread或者说per cpu workqueue上的指定的work，其callback是不会在一个cpu上并发执行（也就是说在多个cpu上可以并发执行）。 CMWQ的概念是类似的，这里就不再赘述了，后面还会有文档描述。

[给力]

@shoujixiaodao：过奖了，下一篇写hotplug吧，多谢关注~~~

写的好，学习了，cpu hotplug 哈时候写一写？多谢！

@heziq：非常好的问题，多谢！但是最近有点忙，而且你的问题不是三言两语就能回答的，稍等两天再回复你。

@linuxer: tasklet 通过 TASKLET_STATE_SCHED 和 TASKLET_STATE_RUN 来防止并发，threaded irq hander 也通过IRQS_ONESHOT防止并发，workequeue是通过什么手段来防止并发的呢？比如我在两个cpu上同时触发同一个workqueue，我看到一个WORK_STRUCT_PENDING 在work提交的时候使用，是不是workqueue采取与taskelet类似的方法，来防止并发，或者根本就由用户自己考虑并发？我自己先在代码中找了好久都没发现，workqueue的代码变复杂了，我有点晕。

@wowo：oops不是很可靠阿 ，，，起码比如说VPU的时钟disable后操作VPU的寄存器，会导致内核freeze，类似与这样的error就不会产生oops。。或者 有些oops还没来得及打到屏幕上，内核就已经挂拉

@paoshapaoxue：是的，没有加超链接的引用，就是没来得及写，抱歉哈

hi，wowo： 你在本文中说的 hot plut 功能可以参考文章“Linux CPU core的电源管理(4)_cpu control” 这个文章我怎么一直没找到呢，是不是还没有完成啊？

@tigger：不好意思，一直空接着写这一块的东西： cpu_online_bits比较容易理解，CPU启动的话（也即CPU运行了kernel代码，secondary_start_kernel），就认为是online的，会通过set_cpu_online接口设置这个bit mask。 而cpu_active_bits，则表示有任务在这个CPU上调度，由kenrel sched模块，调用set_cpu_active设置。 online和active的区别是，只要active，一定是online，因此online更多的代码了CPU的“物理状态”，而active，更多的是OS调度层面的抽象，CPU本身没有这一个状态。