前文我们讲了workqueue的接口，实现，及线程池的创建，现在我们讲一下线程的管理调度，及工作任务函数的执行逻辑。工作队列的管理及调度操作有三个部分，分别是空闲线程管理，求救逻辑处理，及工作者线程。

空闲线程管理

空闲线程管理通过计时器定期检查线程池中是否有太多的空闲线程，如果空闲线程的数量合理，则退出，否则判断线程空闲时长是否超时以决定是否销毁线程。由于空闲线程是按空闲时间先进先出排列的，所以只需要判断第一个线程是否超时即可，如果空闲时间大于IDLE_WORKER_TIMEOUT（5分钟）则销毁线程，然后继续判断下一个空闲线程，否则设置下一次调度时间并退出。

1815行，判断是否太多空闲线程

1820行，取出第一个空闲线程，由于空闲线程是按空闲的先进先出排列的，所以第一个线程就是空闲时间最久的线程。

1823行，判断空闲时间是否超时。

1824行，修改下一次调度时间为线程超时时间，因为线程如果没有达到超时的话，即使调度了也没有用，白白浪费CPU时间。

1828行，销毁线程。

too_many_workers()函数判断是否太多空闲线程。

823行，获取空闲线程数量

814行，获取运行线程数量

816行，判断是否太多空闲线程的依据是空闲线程数量是否大于运行数量的1/4。

destroy_worker()函数销毁一个线程。

1793行，用于判断检测线程死锁。

1801，1802行，线程池管理的线程数减一，空闲数减一。

1805行，销毁线程并不会暴力地删除它，而是把线程标志设为WORKER_DIE，这样线程在下一个执行循环的时候就会检测到此标志，释放资源退出执行。

求救逻辑处理

求救逻辑处理计通过时器通过判断是否需要创建更多的线程来决定是否发送求救信号，因为线程一旦需要创建的时候就已经被创建了，不会等到求救计时器来检查，一旦检查到，就说明资源已经得不到满足了，这时就需要发送求救信号，触发rescue线程接管处理。

1865行，检测是否线程不能满足工作任务的需求。

1872，1873行，向任务链表中的每一个任务都发生求救信号。

1879行，设置求救计时器下一次执行时间为MAYDAY_INTERVAL（100ms）后。

1842行，如果没有创建rescue线程，不作处理，直接退出。

1852行，把pwq中的mayday_node,加入到wq中的maydays里，一个工队列可能连接到不同的pool里，也就是说会有多个pwq对象，但rescue线程只会创建一个，所以需要把求救任务归结在一起进行处理。

1853行，唤醒rescue线程。

rescuer_thread()函数是rescue任务处理线程函数。

2249行，rescue线程设置自己为最高优先级。

2257行，设置可中断睡眠状态。

2267行，线程是否应该退出，如果是则执行完rescue任务后退出。

2270行，进入自旋锁，防止其他rescue线程重入。

2272行，只要队列中的maydays链表不为空，就会持续执行rescue任务。

2283行，把rescue线程绑定到线程池中去。

2295行，把pool中任务列表worklist中的任务加到rescue的scheduled中去。

2298行，调度执行rescue中的任务。

2334行，rescue任务执行完毕，取消与pool的绑定，然后再次判断有没有求救任务，如果有继续进入循环继续处理。

2341-2345行，如果rescue线程需要退出，此时就是退出的时机。

2349行， 否则，调度其他线程，一旦调度，将不知道什么时候再回来，但终会回来继续运行，所以回来后马上跳回repeat标号除继续执行。

工作者线程

工作者线程是工作队列的主要引擎，不但推动执行每一个工作任务，而且参与管理线程池事务。线程进入管理功能后，将根据状态判断是否创建更多的工作者线程。一个时刻只有一个线程管理线程池事物，其他线程执行任务列表中的工作任务。

2151行，工作者线程判断自身是否设置了WORKER_DIE标识，此标志由空闲管理计时器在空闲线程太多的时候设置，如果有这标志，线程清理资源自行退出。

2166行，判断线程池是否需要更多的线程，如果不需要，表示没有任务可做，跳转到sleep标号进行调度处理。

2170行，进入管理工作，管理所属线程池事务。

2190-2203行，取出工作任务对象，然后执行任务。

manage_workers()函数主要管理更多线程的创建以完成工作任务。

1957行，判断线程池是否已经有其他线程充当管理者角色，有则退出。

1960行，设置此线程接管线程池管理者角色。

1963行，管理线程池，创建更多的线程。

maybe_create_worker ()创建更多的工作者线程，并协调求救计时器工作。

1980行，修改求救计时器触发时间，这样管理者和计时器逻辑不会冲突。

1911行，创建工作者线程，如果创建成功退出循环。

1914行，如果创建失败，进入睡眠，调度器在某个时候会再度唤醒此线程。

1916行，如果线程池不需要创建线程，则退出循环。

1920行，管理者如果退出了循环，说明任务已获得资源处理，这时只需停止求救计时器即可，如果没有足够的资源处理任务，则会在循环中不出来，这样求救计时器就会如期地执行。

1927行，如果此时仍然有任务需要处理跳到restart标号处继续处理。

process_one_work()函数是执行工作任务的具体函数，主要功能就是获取任务回调函数指针，然后执行它。

2015-2028行，获取任务的函数。

2064行，执行任务函数。

至此，工作队列的线程管理，调度，及rescue逻辑就基本讲完了，很多时候我们并不需要自己创建单独的队列，只需使用默认的工作队列即可。

（armv8，kernel4.4）

相关文章

Linux工作队列workqueue源码分析（一）

Linux工作队列workqueue源码分析（二）

Linux工作队列workqueue源码分析（三）

Linux系统调用源码分析（四）