?
可以看到,在queue里的任务,不仅仅是一个函数,也可以是一个其他的queue。 下面是一个例子。
?
全局队列的处理
一般一个全局队列有多个线程,这些个线程会遍历并处理链表里的任务。
对于全局队列,当一个任务被抛进来后,会尽快处理掉。
如果有空闲线程,那么这个空闲线程会处理这个任务。
如果没有空闲线程,那么会新开一个线程来处理。
空闲线程来自哪里呢?
do {
_dispatch_worker_thread2(context);
// we use 65 seconds in case there are any timers that run once a minute
} while (dispatch_semaphore_wait(qc->dgq_thread_mediator, dispatch_time(0, 65ull * NSEC_PER_SEC)) == 0);
在线程开启以后,通过_dispatch_worker_thread2
来遍历任务。
当遍历结束以后,会保活65s
。
这样子,就不用频繁的生成线程。
这就是全局队列dgq_thread_mediator
的用处。
下面是判断是否有空闲线程的代码。
if (dispatch_semaphore_signal(qc->dgq_thread_mediator)) {
goto out;
}
如何处理队列里的任务
while ((item = fastpath(_dispatch_queue_concurrent_drain_one(dq)))) {
_dispatch_continuation_pop(item);
}
第一行是从queue
里拿一个任务,第二行是处理这个任务。
注意,可能有多个线程同时去调用_dispatch_queue_concurrent_drain_one
,因此这里函数里有很多原子操作与判断逻辑。
下面是_dispatch_continuation_pop
的流程图。
一个流程走完,队列里的任务就会少一个。
?
原文地址:https://www.cnblogs.com/huahuahu/p/dispatch-queue-zhi-dispatchasync.html
时间: 2024-10-04 02:07:45