我们都知道runloop是一个循环，那么我有这么一个问题，dispatch_get_main_queue()是在当次循环还是下次循环执行。于是，进行了下面这波测试和分析。
dispatch_async(dispatch_get_main_queue(), ^{
NSLog(@"1");
});
先通过监听runloop的各个状态来测试
void myRunLoopObserver(CFRunLoopObserverRef observer, CFRunLoopActivity activity, void *info)
{
switch(activity)
{
// 即将进入Loop
case kCFRunLoopEntry:
NSLog(@"run loop entry");
break;
case kCFRunLoopBeforeTimers://即将处理 Timer
NSLog(@"run loop before timers");
break;
case kCFRunLoopBeforeSources://即将处理 Source
NSLog(@"run loop before sources");
break;
case kCFRunLoopBeforeWaiting://即将进入休眠
NSLog(@"run loop before waiting");
break;
case kCFRunLoopAfterWaiting://刚从休眠中唤醒
NSLog(@"run loop after waiting");
break;
case kCFRunLoopExit://即将退出Loop
NSLog(@"run loop exit");
break;
default:
break;
}
}
image.png
通过上面分析，感觉是下次循环。
image.png
CFRUNLOOP_IS_SERVICING_THE_MAIN_DISPATCH_QUEUE 这个东西是什么呢？
然后又去找了下源码。
CFRUNLOOP_IS_CALLING_OUT_TO_AN_OBSERVER_CALLBACK_FUNCTION
CFRunloop is calling out to an abserver callback function
用于向外部报告 RunLoop 当前状态的更改，框架中很多机制都由 RunLoopObserver 触发，如 CAAnimation
CFRUNLOOP_IS_CALLING_OUT_TO_A_BLOCK
CFRunloop is calling out to a block
消息通知、非延迟的perform、dispatch调用、block回调、KVO
CFRUNLOOP_IS_SERVICING_THE_MAIN_DISPATCH_QUEUE
CFRunloop is servicing the main desipatch queue
CFRUNLOOP_IS_CALLING_OUT_TO_A_TIMER_CALLBACK_FUNCTION
CFRunloop is calling out to a timer callback function
延迟的perform, 延迟dispatch调用
CFRUNLOOP_IS_CALLING_OUT_TO_A_SOURCE0_PERFORM_FUNCTION
CFRunloop is calling out to a source 0 perform function
处理App内部事件、App自己负责管理（触发），如UIEvent、CFSocket。普通函数调用，系统调用
CFRUNLOOP_IS_CALLING_OUT_TO_A_SOURCE1_PERFORM_FUNCTION
CFRunloop is calling out to a source 1 perform function
看到这里好像还不能知道为什么。
{
// 1.1 通知Observers，即将进入RunLoop
// 此处有Observer会创建AutoreleasePool: _objc_autoreleasePoolPush();
__CFRUNLOOP_IS_CALLING_OUT_TO_AN_OBSERVER_CALLBACK_FUNCTION__(kCFRunLoopEntry);
do {
// 2.1 通知 Observers: 即将触发 Timer 回调。
__CFRUNLOOP_IS_CALLING_OUT_TO_AN_OBSERVER_CALLBACK_FUNCTION__(kCFRunLoopBeforeTimers);
// 2.2 通知 Observers: 即将触发 Source (非基于port的,Source0) 回调。
__CFRUNLOOP_IS_CALLING_OUT_TO_AN_OBSERVER_CALLBACK_FUNCTION__(kCFRunLoopBeforeSources);
// 执行Block
__CFRUNLOOP_IS_CALLING_OUT_TO_A_BLOCK__(block);
// 2.3 触发 Source0 (非基于port的) 回调。
__CFRUNLOOP_IS_CALLING_OUT_TO_A_SOURCE0_PERFORM_FUNCTION__(source0);
// 执行Block
__CFRUNLOOP_IS_CALLING_OUT_TO_A_BLOCK__(block);
// 3.1 通知Observers，即将进入休眠
// 此处有Observer释放并新建AutoreleasePool: _objc_autoreleasePoolPop(); _objc_autoreleasePoolPush();
__CFRUNLOOP_IS_CALLING_OUT_TO_AN_OBSERVER_CALLBACK_FUNCTION__(kCFRunLoopBeforeWaiting);
// 3.2 sleep to wait msg.
mach_msg() -> mach_msg_trap();
// 3.3 通知Observers，线程被唤醒
__CFRUNLOOP_IS_CALLING_OUT_TO_AN_OBSERVER_CALLBACK_FUNCTION__(kCFRunLoopAfterWaiting);
// 4.1 如果是被Timer唤醒的，回调Timer
__CFRUNLOOP_IS_CALLING_OUT_TO_A_TIMER_CALLBACK_FUNCTION__(timer);
// 4.2 如果是被dispatch唤醒的，执行所有调用 dispatch_async 等方法放入main queue 的 block
__CFRUNLOOP_IS_SERVICING_THE_MAIN_DISPATCH_QUEUE__(dispatched_block);
// 4.3 如果如果Runloop是被 Source1 (基于port的) 的事件唤醒了，处理这个事件
__CFRUNLOOP_IS_CALLING_OUT_TO_A_SOURCE1_PERFORM_FUNCTION__(source1);
// 5. 退出判断函数调用栈无显示
} while (...);
// 6. 通知Observers，即将退出RunLoop
// 此处有Observer释放AutoreleasePool: _objc_autoreleasePoolPop();
__CFRUNLOOP_IS_CALLING_OUT_TO_AN_OBSERVER_CALLBACK_FUNCTION__(kCFRunLoopExit);
}
看完上面的内容，我觉得可以这么理解，通过dispatch_asyn注册到observer中，当runloop下次循环的时候，执行所有通过dispatch_asyn添加进去的事件。
所以应该是下次循环。
看一下下面的代码，理解可能会更深一点。
/**
* 运行run loop
*
* @param rl 运行的RunLoop对象
* @param rlm 运行的mode
* @param seconds run loop超时时间
* @param stopAfterHandle true:run loop处理完事件就退出 false:一直运行直到超时或者被手动终止
* @param previousMode 上一次运行的mode
*
* @return 返回4种状态
*/
static int32_t __CFRunLoopRun(CFRunLoopRef rl,
CFRunLoopModeRef rlm,
CFTimeInterval seconds,
CFRunLoopModeRef previousMode) {
// 借助GCD timer，设置runloop的超时时间
dispatch_source_t timeout_timer = ...
// 超时回调函数 __CFRunLoopTimeout
dispatch_source_set_event_handler_f(timeout_timer, __CFRunLoopTimeout);
// 超时取消函数 __CFRunLoopTimeoutCancel
dispatch_source_set_cancel_handler_f(timeout_timer, __CFRunLoopTimeoutCancel);
// 进入do while循环，开始run
int32_t retVal = 0; // runloop run返回值，默认为0，会在do while中根据情况被修改，当不为0时，runloop退出
do{
mach_port_t livePort = MACH_PORT_NULL; // 用于记录唤醒休眠的RunLoop的mach port，休眠前是NULL
__CFPortSet waitSet = rlm->_portSet; // 取当前mode所需要监听的mach port集合，用于唤醒runloop（__CFPortSet 实际上是unsigned int 类型）
__CFRunLoopDoObservers(rl, rlm, kCFRunLoopBeforeTimers); // 通知 即将处理 Timers
__CFRunLoopDoObservers(rl, rlm, kCFRunLoopBeforeSources); // 通知 即将处理 sources
// 处理提交到runloop的blocks
__CFRunLoopDoBlocks(rl, rlm);
// 处理 source0
Boolean sourceHandledThisLoop = __CFRunLoopDoSources0(rl, rlm, stopAfterHandle);
if (sourceHandledThisLoop) {
__CFRunLoopDoBlocks(rl, rlm); // 处理提交的runloop的block
}
// 如果有source1被signaled，则不休眠，直接跳到handle_msg来处理source1
if (__CFRunLoopServiceMachPort(dispatchPort, &msg, sizeof(msg_buffer), &livePort, 0, &voucherState, NULL)) {
goto handle_msg;
}
__CFRunLoopDoObservers(rl, rlm, kCFRunLoopBeforeWaiting); // 通知observer before waiting
// ****** 开始休眠 ******
__CFRunLoopServiceMachPort(waitSet, &msg, sizeof(msg_buffer), &livePort, poll ? 0 : TIMEOUT_INFINITY, &voucherState, &voucherCopy); // 调用__CFRunLoopServiceMachPort, 监听waitSet所指定的mach port端口集合, 如果没有port message，进入 mach_msg_trap, RunLoop休眠,直到收到port message或者超时
// ****** 休眠结束 ******
__CFRunLoopDoObservers(rl, rlm, kCFRunLoopAfterWaiting); // 通知observer， runloop醒了
handle_msg:; // 处理事件
// 根据唤醒RunLoop的livePort值，来进行对应逻辑处理
if (MACH_PORT_NULL == livePort) { // MACH_PORT_NULL: 可能是休眠超时，啥都不做
CFRUNLOOP_WAKEUP_FOR_NOTHING();
// handle nothing
} else if (livePort == rl->_wakeUpPort) { // rl->_wakeUpPort: 被其他线程或进程唤醒，啥都不做
CFRUNLOOP_WAKEUP_FOR_WAKEUP();
// do nothing on Mac OS
} else if (rlm->_timerPort != MACH_PORT_NULL && livePort == rlm->_timerPort) // rlm->_timerPort: 处理nstimer 消息
if (!__CFRunLoopDoTimers(rl, rlm, mach_absolute_time())) {
// Re-arm the next timer
__CFArmNextTimerInMode(rlm, rl);
}
}else if (livePort == dispatchPort) // dispatchPort:处理分发到main queue上的事件
{
__CFRUNLOOP_IS_SERVICING_THE_MAIN_DISPATCH_QUEUE__(msg);
}else { // 其余的，肯定是各种source1 事件
__CFRunLoopDoSource1(rl, rlm, rls, msg, msg->msgh_size, &reply)
if (NULL != reply) { // 如果有需要回复soruce1的消息，则回复
(void)mach_msg(reply, MACH_SEND_MSG, reply->msgh_size, 0, MACH_PORT_NULL, 0, MACH_PORT_NULL);
CFAllocatorDeallocate(kCFAllocatorSystemDefault, reply);
}
}
// ****** 到这里就结束了对livePort的处理 ******
__CFRunLoopDoBlocks(rl, rlm); // 处理提交到runloop的blocks
// 检查runloop是否需要退出
if (sourceHandledThisLoop && stopAfterHandle) { // case1. 指定了仅处理一个source 退出kCFRunLoopRunHandledSource
retVal = kCFRunLoopRunHandledSource;
} else if (timeout_context->termTSR < mach_absolute_time()) { // case2. RunLoop 超时
retVal = kCFRunLoopRunTimedOut;
} else if (__CFRunLoopIsStopped(rl)) { // case3. RunLoop 被终止
__CFRunLoopUnsetStopped(rl);
retVal = kCFRunLoopRunStopped;
} else if (rlm->_stopped) { // case4. RunLoop Mode 被终止
rlm->_stopped = false;
retVal = kCFRunLoopRunStopped;
} else if (__CFRunLoopModeIsEmpty(rl, rlm, previousMode)) { // case5. RunLoop Mode里面没有任何要被处理的事件了（没有source0，source1， timer，以及提交到当前runloop mode的block)
retVal = kCFRunLoopRunFinished;
}
}while(0 == retVal);
// runloop循环结束，返回退出原因
return retVal;
}
