1、我們先來看看CFRunLoopRun的實現(xiàn)

https://opensource.apple.com/tarballs/CF/

void CFRunLoopRun(void) {   /* DOES CALLOUT */
    int32_t result;
    do {
        result = CFRunLoopRunSpecific(CFRunLoopGetCurrent(), kCFRunLoopDefaultMode, 1.0e10, false);
        CHECK_FOR_FORK();
    } while (kCFRunLoopRunStopped != result && kCFRunLoopRunFinished != result);
}

我們可以看到CFRunLoopRun()里面就是一個do while循環(huán)，如果沒有停止或結(jié)束就一直運行，
真正調(diào)用的是CFRunLoopRunSpecific()，它有4個參數(shù)
1)、CFRunLoopRef rl ：runloop，這里是傳入了當前runloop
2)、CFStringRef modeName ：runllop mode，這里傳入了默認模式
3)、CFTimeInterval seconds ：循環(huán)執(zhí)行任務(wù)的時間
4)、Boolean returnAfterSourceHandled ：
這個根據(jù)官方文檔
A flag indicating whether the run loop should exit after processing one source. If false, the run loop continues processing events until seconds has passed.
就是一個標記，如果設(shè)置為true，執(zhí)行完一個source后退出，如果為false，一直循環(huán)執(zhí)行事件直到經(jīng)過了上一個參數(shù)設(shè)置的這個秒數(shù)

2、CFRunLoopRunSpecific()的實現(xiàn)

SInt32 CFRunLoopRunSpecific(CFRunLoopRef rl, CFStringRef modeName, CFTimeInterval seconds, Boolean returnAfterSourceHandled) {     /* DOES CALLOUT */
    CHECK_FOR_FORK();
    //1、如果runloop被釋放，直接返回finished
    if (__CFRunLoopIsDeallocating(rl)) return kCFRunLoopRunFinished;
    __CFRunLoopLock(rl);
    //2、通過runloop mode名字找到runloop mode
    CFRunLoopModeRef currentMode = __CFRunLoopFindMode(rl, modeName, false);
    //3、如果mode不存在或者為空，則返回finished
    if (NULL == currentMode || __CFRunLoopModeIsEmpty(rl, currentMode, rl->_currentMode)) {
        Boolean did = false;
        if (currentMode) __CFRunLoopModeUnlock(currentMode);
        __CFRunLoopUnlock(rl);
        return did ? kCFRunLoopRunHandledSource : kCFRunLoopRunFinished;
    }
    //4、緩存運行數(shù)據(jù)并給runloop設(shè)置新數(shù)據(jù)
    volatile _per_run_data *previousPerRun = __CFRunLoopPushPerRunData(rl);
    //5、獲取runloop上一次執(zhí)行的mode
    CFRunLoopModeRef previousMode = rl->_currentMode;
    //6、設(shè)為執(zhí)行mode為傳入?yún)?shù)獲取到的
    rl->_currentMode = currentMode;
    int32_t result = kCFRunLoopRunFinished;
    //7、如果當前mode標記了進入runloop通知，則通知進入runloop
    if (currentMode->_observerMask & kCFRunLoopEntry ) __CFRunLoopDoObservers(rl, currentMode, kCFRunLoopEntry);
    //8、執(zhí)行runloop
    result = __CFRunLoopRun(rl, currentMode, seconds, returnAfterSourceHandled, previousMode);
    //9、如果當前Mode標記了退出runloop通知，則通知退出runloop
    if (currentMode->_observerMask & kCFRunLoopExit ) __CFRunLoopDoObservers(rl, currentMode, kCFRunLoopExit);

        __CFRunLoopModeUnlock(currentMode);
    //10、將第4步獲取的運行數(shù)據(jù)賦給runloop
        __CFRunLoopPopPerRunData(rl, previousPerRun);
    //11、還原runloop的mode為上一次的
    rl->_currentMode = previousMode;
    __CFRunLoopUnlock(rl);
    return result;
}

這里我們可以得出這個函數(shù)做了以下事
1)、判斷是要運行的runloop和Mode是否可以運行
2)、緩存上一次的_per_run_data和mode，并給runloop新值
3)、通知進入runloop
4)、運行runloop
5)、通知退出runloop
6)、還原上一次的_per_run_data和mode

3、__CFRunLoopRun() 這個方法太多，我們簡化一下

static int32_t __CFRunLoopRun(CFRunLoopRef rl, CFRunLoopModeRef rlm, CFTimeInterval seconds, Boolean stopAfterHandle, CFRunLoopModeRef previousMode) {
    do {
        //1、通知開始調(diào)用定時器
        if (rlm->_observerMask & kCFRunLoopBeforeTimers) __CFRunLoopDoObservers(rl, rlm, kCFRunLoopBeforeTimers);
        //2、通知開始執(zhí)行source0(用戶創(chuàng)建的source)
        if (rlm->_observerMask & kCFRunLoopBeforeSources) __CFRunLoopDoObservers(rl, rlm, kCFRunLoopBeforeSources);
        
        //3、開始執(zhí)行runloop的block鏈表 block由CFRunLoopPerformBlock插入runloop
        __CFRunLoopDoBlocks(rl, rlm);
        
        //4、執(zhí)行source0操作
        Boolean sourceHandledThisLoop = __CFRunLoopDoSources0(rl, rlm, stopAfterHandle);
        if (sourceHandledThisLoop) {
            //執(zhí)行block
            __CFRunLoopDoBlocks(rl, rlm);
        }
                
        //5、如果有新的mach_port消息，跳轉(zhuǎn)處理mach_port消息(source1)
        if (MACH_PORT_NULL != dispatchPort && !didDispatchPortLastTime) {
            //獲取source1信息
            if (__CFRunLoopServiceMachPort(dispatchPort, &msg, sizeof(msg_buffer), &livePort, 0, &voucherState, NULL)) {
                //跳轉(zhuǎn)
                goto handle_msg;
            }
        }
                
        //6、通知即將進入等待
        if (!poll && (rlm->_observerMask & kCFRunLoopBeforeWaiting)) __CFRunLoopDoObservers(rl, rlm, kCFRunLoopBeforeWaiting);

        //7、休眠等待
        __CFRunLoopServiceMachPort(waitSet, &msg, sizeof(msg_buffer), &livePort, poll ? 0 : TIMEOUT_INFINITY, &voucherState, &voucherCopy);

        
        //8、通知runloop退出休眠
        if (!poll && (rlm->_observerMask & kCFRunLoopAfterWaiting)) __CFRunLoopDoObservers(rl, rlm, kCFRunLoopAfterWaiting);
        
    handle_msg:;
        //9、處理喚醒消息
       //9.1、處理timer事件
        if (modeQueuePort != MACH_PORT_NULL && livePort == modeQueuePort) {
            if (!__CFRunLoopDoTimers(rl, rlm, mach_absolute_time())) {
                // Re-arm the next timer, because we apparently fired early
                __CFArmNextTimerInMode(rlm, rl);
            }
        }
        //9.2、如果是 gcd的main queue
        else if (livePort == dispatchPort) {
            __CFRUNLOOP_IS_SERVICING_THE_MAIN_DISPATCH_QUEUE__(msg);
 
        }
        //9.3、如果是source1事件
         else {
 
            //更具mach port端口獲取source1事件
            CFRunLoopSourceRef rls = __CFRunLoopModeFindSourceForMachPort(rl, rlm, livePort);
            //處理source1事件
            sourceHandledThisLoop = __CFRunLoopDoSource1(rl, rlm, rls, msg, msg->msgh_size, &reply) || sourceHandledThisLoop;
            (void)mach_msg(reply, MACH_SEND_MSG, reply->msgh_size, 0, MACH_PORT_NULL, 0, MACH_PORT_NULL);
            
        }

        //10、執(zhí)行block
        __CFRunLoopDoBlocks(rl, rlm);
        
        //11、判斷是否退出循環(huán)
        if (sourceHandledThisLoop && stopAfterHandle) {
            retVal = kCFRunLoopRunHandledSource;
        } else if (timeout_context->termTSR < mach_absolute_time()) {
            retVal = kCFRunLoopRunTimedOut;
        } else if (__CFRunLoopIsStopped(rl)) {
            __CFRunLoopUnsetStopped(rl);
            retVal = kCFRunLoopRunStopped;
        } else if (rlm->_stopped) {
            rlm->_stopped = false;
            retVal = kCFRunLoopRunStopped;
        } else if (__CFRunLoopModeIsEmpty(rl, rlm, previousMode)) {
            retVal = kCFRunLoopRunFinished;
        }

        
    } while (0 == retVal);
    
    
    return retVal;
}

具體邏輯流程我們借用網(wǎng)上的一個圖片

avatar

這里的source0是用戶事件，source1是系統(tǒng)通過match port發(fā)送的消息事件

4、這里runloop runloopMode source timer observer之間的關(guān)系我們也借用網(wǎng)上一個圖片

avatar

1)、runloop一次只能在一種RunLoopMode下執(zhí)行
1)、每個RunLoopMode包含各自的事件