深入理解Runloop，看我一篇就够了

Posted 喵渣渣

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了深入理解Runloop，看我一篇就够了相关的知识，希望对你有一定的参考价值。

前言

RunLoop 是 ios 和 OSX 开发中非常基础的一个概念，为了让大家更加快速融入，请先一段代码：

+ (NSThread *)networkRequestThread 
    static NSThread *_networkRequestThread = nil;
    static dispatch_once_t oncePredicate;
    dispatch_once(&oncePredicate, ^
        _networkRequestThread = [[NSThread alloc] initWithTarget:self selector:@selector(networkRequestThreadEntryPoint:) object:nil];
        [_networkRequestThread start];
    );
    return _networkRequestThread;


+ (void)networkRequestThreadEntryPoint:(id)__unused object 
    @autoreleasepool 
        [[NSThread currentThread] setName:@"AFNetworking"];
        NSRunLoop *runLoop = [NSRunLoop currentRunLoop];
        [runLoop addPort:[NSMachPort port] forMode:NSDefaultRunLoopMode];
        [runLoop run];

以上是AFN2.x的一段经典代码

  • 首先我们要明确一个概念，线程一般都是一次执行完毕任务，就销毁了。
  • 而在线程中添加了runloop，并运行起来，实际上是添加了一个do，while循环，这样这个线程的程序就一直卡在do，while循环上，这样相当于线程的任务一直没有执行完，所有线程一直不会销毁。
  • 所有，一旦我们添加了一个runloop，并run了，我们如果要销毁这个线程，必须停止runloop，至于停止的方式，我们接着往下看。

这里创建了一个线程，取名为AFNetworking，因为添加了一个runloop，所以这个线程不会被销毁，直到runloop停止。

[runloop addPort: [NSMachPort port] forMode: NSDefaultRunLoopMode];
  • 这行代码的目的是添加一个端口监听这个端口的事件，这也是我们后面会讲到的一种线程见的通信方式-基于端口的通信。
[runloop run];
  • runloop开始跑起来，但是要注意，这种runloop，只有一种方式能停止。
[NSRunloop currentRunloop] removePort: <#(nonnull NSPort)#> forMode: <#(nonull NSRunLoopMode)#>
  • 只有从runloop中移除我们之前添加的端口，这样的runloop没有任何事件，所有直接退出。

再次回到AFN2.x的这行源码上，因为他用的是run，而且并没有记录下自己添加的NSMachPort,所有显然，它没有打算退出这个runloop，这是一个常驻线程。事实上，看过AFN2.x源码的同学都会知道，这个thread需要常驻的原因，在此就不做赘述了。

接下来我们看看AFN3.x是怎么用runloop的：

需要开启的时候：

CFRunLoopRun();

终止的时候：

CFRunloopStop(CFRunLoopGetCurrent());
  • 由于NSUrlSession参考了AFN2.x的优点，自己维护了一个线程池，做Request线程的调度与管理，所有在AFN3.x中，没有了常驻线程，都是用的run，结束的时候stop。

再看RAC中runloop：

do 
    [NSRunloop.mainRunloop runMode:NSDefaultRunLoopMode beforeDate: [NSDate dateWithTimeIntervalSinceNow: 0.1]];
 while(!done);
  • 大致讲下这段代码实现的内容，自己用一个Bool值done去控制runloop的运行，每次只运行这个模式的runloop，0.1秒。0.1秒后开启runloop的下次运行。

以上我们都大致分析一下，后面我们再来讲为什么。

首先我们讲讲runloop的概念

  • Runloop，顾名思义就是跑圈，他的本质就是一个do，while循环，当有事做时就做事，没事做时就休眠。至于怎么做事，怎么休眠,这个是由系统内核来调度的，我们后面会讲到。

  • 每个线程都由一个Run Loop，主线程的Run Loop会在App运行的时自动运行，子线程需要手动获取运行，第一次获取时，才会去创建。

  • 每个Run Loop都会以一个模式mode来运行，可以使用NSRunLoop的方法运行在某个特定的mode。

- (BOOL)runMode:(NSString *)mode beforeDate:(NSDate *)limitDate;

  • Run Loop的处理两大类事件源：Timer Source和Input Source(包括performSelector *方法簇、Port或者自定义的Input Source），每个事件源都会绑定在Run Loop的某个特定模式mode上，而且只有RunLoop在这个模式下运行的时候，才会触发Timer和Input Source。

  • 最后，如果没有和人事件源添加到Run Loop上，Run Loop就会立刻exit，这也是一开始AFN例子，为什么需要绑定一个Port的原因。

我们先来谈谈RunLoop Mode

OS下Run Loop的主要运行模式mode有：
1）NSDefaultRunLoopMode：默认的运行模式，除了NSConnection对象的事件。
2）NSRunLoopCommonModes：是一组常用的模式集合，将一个input source关联到这个模式集合上，等于将input source关联到这个模式集合中的所有模式上。在iOS系统中NSRunLoopCommonMode包含NSDefaultRunLoopMode、NSTaskDeathCheckMode、UITrackingRunLoopMode。

  • 假如我有个timer要关联到这些模式上，一个个注册很麻烦，我可以用：
CFRunLoopAddCommonMode([[NSRunLoop currentRunLoop] getCFRunLoop],(__bridge CFStringRef) UITrackingRunLoopMode);

将UITrackingRunLoopMode或者其他模式添加到这个NSRunLoopCommonModes模式中，然后只需要将Timer关联到NSRunLoopCommonModes，即可以实现RunLoop运行在这个模式集合中任意一个模式时，这个Timer都可以触发。

  • 当然，默认情况下NSRunLoopCommonModes包含了NSDefaultRunLoopMode和UITrackingRunLoopMode。我指的是如果有其他自定义的Mode。

  • 注意： 让Run Loop运行在NSRunLoopCommonModes下是没有意义的，因为一个时刻Run Loop只能运行在一个特定模式下，而不可能是个模式集合。

3）UITrackingRunLoopMode：用于跟踪触摸事件触发的模式(例如UIScrollView上下滚动）， 主线程当触摸事件触发会设置为这个模式，可以用来在控件事件触发过程中设置Timer。
4) GSEventReceiveRunLoopMode：用于接受系统事件，属于内部的Run Loop模式。
5）自定义Mode：可以设置自定义的运行模式Mode，你也可以用CFRunLoopAddCommonMode添加到NSRUnLoopCommonModes中。

总结一下：

Run Loop 运行时只能以一种固定的模式运行，如果我们需要它切换模式，只有停掉它，再重新开其它
运行时它只会监控这个模式下添加的Timer Source和Input Source，如果这个模式下没有相应的事件源，RunLoop的运行也会立刻返回的。注意Run Loop不能在运行在NSRunLoopCommonModes模式，因为NSRunLoopCommonModes其实是个模式集合，而不是一个具体的模式，我可以添加事件源的时候使用NSRunLoopCommonModes，只要Run Loop运行在NSRunLoopCommonModes中任何一个模式，这个事件源都可以被触发。

Run Loop运行接口

  • 要操作Run Loop，Foundation层和Core Foundation层都有相应的接口可以操作Run Loop：Foundation层对应的是NSRunLoop，Core Foundation层对应的是CFRunLoopRef；
    Foundation层对应的是NSRunLoop，Core Foundation层对应的是CFRunLoopRef；

*两组接口差不多，不过功能上还是有许多区别的：
例如CF层可以添加自定义的Input Source事件源、(CFRunLoopSourceRef)RunLoop观察者Observer(CFRunLoopObserverRef)，很多类似功能的接口特性也是不一样的。
NSRunLoop的运行接口：

// 运行NSRunLoop，运行模式为默认的NSDefaultRunLoopMode模式，没有超时限制
- （void）run；
// 运行NSRunLoop：参数为时间期限，运行模式为默认的NSDefaultRunLoopMode模式
- (void)runUntilDate:(NSDate *)limitDate;
// 运行NSRunLoop：参数为运行模式、时间期限，返回值为YES表示处理事件后返回的，NO表示是超时或者停止运行导致返回的。
- (BOOL)runMode:(NSString *)mode beforeDate:(NSDtate *)limitDate;

CFRunLoopRef的运行接口：

// 运行CFRunLoopRef
void CFRunLoopRun();
// 运行CFRunLoopRef:参数为运行模式、时间和是否在处理Input Source后退出标志，返回值是exit原因
SInt32 CFRunLoopRunInMode(mode, second, returnAfterSourceHandled);
// 停止运行CFRunLoop
void CFRunLoopStop(CFRunLoopRef rl);
// 唤醒CFRunLoopRef
void CFRunLoopWakeUp(CFRunLoopRef rl);

首先，详细讲解下NSRunLoop的三个运行接口：

First

- (void)run; // 无条件运行

  • 不建议使用，因为这个接口会导致Run Loop永久性的在NSDefaultRunLoopMode模式。

  • 即使用CFRunLoopStop(runloopRef);也无法停止Run Loop的运行，除非能移除这个runloop上的所有事件源，包括定时器和source时间，不然这个子线程就无法停止，只能永久运行下去。

Second

- (void)runUntilDate:(NSDate *)limitDate; // 有一个超时时间限制

  • 比上面的接口好点，有个超时时间，可以控制每次Run Loop的运行时间，也是运行在NSDefaultRunLoopMode模式。
    这个方法运行Run Loop一段时间会退出给你检查运行条件的机会，如果需要可以再次运行Run Loop。

  • 注意CFRunLoopStop(runloopRef), 也无法停止Run Loop的运行。
    使用如下的代码：

while(!Done) 
    [[NSRunLoop currentRunLoop] runUntilDate:[NSDate dateWithTimeIntervalSinceNow: 10]];
    NSLog(@"exiting runloop, ......");

  • 注意这个Done是我们自定义的一个Bool值，用来控制是否还需要开启下一次runloop。

  • 这个例子大概做了如下的事情： 这个RunLoop会每10秒退出一次，然后输出exiting runloop ……,然后下次根据我们的Done值来判断是否再去运行runloop。

Third

// 有一个超时时间限制，而且设置运行模式
- (BOOL)runMode:(NSString *)mode beforeDate:(NSDate *)limitDate;

  • 从方法上来看，比上面多了一个参数，可以设置运行模式。

  • 由一点需要注意:这种运行方式是可以被CFRunLoopStop(runloopRef)所停止的(大家可以自己写个例子试试)。

  • 除此之外，这个方法和第二个方法还有一个很大的区别，就是这样去运行runloop会多一种退出方式。这里我指的退出方式是除了timer触发以外的事件，都会导致runloop退出，这里举个简答的例子：

- (void)testDemo1
    dispatch_async(dispatch_get_global_queue(0,0), ^ 
        NSLog(@"线程开始");
        // 获取当前线程
        self.thread = [NSThread currentThread];
        NSRunLoop *runloop = [NSRunLoop currentRunLoop];
        // 添加一个Port，同理为了防止runloop没事干直接退出
        [runloop addPort: [NSMachPort port] forMode: NSDefaultRunLoopMode];
        // 运行一个runloop， [NSDate distantFuture]:很久很久以后才让它失效
        [runloop runMode:NSDefaultRunloopMode beforeDate: [NSDate distantFuture]];
        NSLog(@"线程结束");
    );
    dispatch_after(dispatch_time(DISPATCH_TIME_NOW,(int64_t)(2*NSEC_PER_SEC)), dispatch_get_main_queue(), ^ 
        // 在我们开启的异步线程调用方法
        [self performSelector:@selector(recieveMsg) onThread: self.thread withObject: nil waitUntilDone: NO];
    );


- (void)recieveMsg 
    NSLog(@"收到消息了，在这个线程：%@"， [NSThread currentThread]);

输出结果如下：

2016-11-22 14:04:15.250 TestRunloop3[70591:1742754] 线程开始
2016-11-22 14:04:17.250 TestRunloop3[70591:1742754] 收到消息了，在这个线程：<NSThread: 0x600000263c80>number = 3, name = (null)
2016-11-22 14:04:17.250 TestRunloop3[70591:1742754] 线程结束

  • 在这里我们用了performSelector: onThread…这个方法去进行线程间的通信，这只是其中最简单的方式。但是缺点也很明显，就是在去调用这个线程的时候，如果线程已经不存在了，程序就会crash。后面我们会仔细讲各种线程间的通信。

  • 我们看到，我们收到一个消息，这个消息是一个 非timer得事件，所有runloop处理完就退出，这里为什么会这样呢，我们可以看看runloop的源代码：

/// RunLoop的实现
int CFRunLoopRunSpecific(runloop, modeName, seconds, stopAfterHandle) 

    /// 首先根据modeName找到对应mode
    CFRunLoopModeRef currentMode = __CFRunLoopFindMode(runloop, modeName, false);
    /// 如果mode里没有source/timer/observer, 直接返回。
    if (__CFRunLoopModeIsEmpty(currentMode)) return;

    /// 1. 通知 Observers: RunLoop 即将进入 loop。
    __CFRunLoopDoObservers(runloop, currentMode, kCFRunLoopEntry);

    /// 内部函数，进入loop
    __CFRunLoopRun(runloop, currentMode, seconds, returnAfterSourceHandled) 

        Boolean sourceHandledThisLoop = NO;
        int retVal = 0;
        do 

            /// 2. 通知 Observers: RunLoop 即将触发 Timer 回调。
            __CFRunLoopDoObservers(runloop, currentMode, kCFRunLoopBeforeTimers);
            /// 3. 通知 Observers: RunLoop 即将触发 Source0 (非port) 回调。
            __CFRunLoopDoObservers(runloop, currentMode, kCFRunLoopBeforeSources);
            /// 执行被加入的block
            __CFRunLoopDoBlocks(runloop, currentMode);

            /// 4. RunLoop 触发 Source0 (非port) 回调。
            sourceHandledThisLoop = __CFRunLoopDoSources0(runloop, currentMode, stopAfterHandle);
            /// 执行被加入的block
            __CFRunLoopDoBlocks(runloop, currentMode);

            /// 5. 如果有 Source1 (基于port) 处于 ready 状态，直接处理这个 Source1 然后跳转去处理消息。
            if (__Source0DidDispatchPortLastTime) 
                Boolean hasMsg = __CFRunLoopServiceMachPort(dispatchPort, &msg)
                if (hasMsg) goto handle_msg;
            

            /// 6.通知 Observers: RunLoop 的线程即将进入休眠(sleep)。
            if (!sourceHandledThisLoop) 
                __CFRunLoopDoObservers(runloop, currentMode, kCFRunLoopBeforeWaiting);
            

            /// 7. 调用 mach_msg 等待接受 mach_port 的消息。线程将进入休眠, 直到被下面某一个事件唤醒。
            /// ? 一个基于 port 的Source 的事件。
            /// ? 一个 Timer 到时间了
            /// ? RunLoop 自身的超时时间到了
            /// ? 被其他什么调用者手动唤醒
            __CFRunLoopServiceMachPort(waitSet, &msg, sizeof(msg_buffer), &livePort) 
                mach_msg(msg, MACH_RCV_MSG, port); // thread wait for receive msg
            

            /// 8. 通知 Observers: RunLoop 的线程刚刚被唤醒了。
            __CFRunLoopDoObservers(runloop, currentMode, kCFRunLoopAfterWaiting);

            /// 9.收到消息，处理消息。
            handle_msg:

            /// 10.1 如果一个 Timer 到时间了，触发这个Timer的回调。
            if (msg_is_timer) 
                __CFRunLoopDoTimers(runloop, currentMode, mach_absolute_time())
             

            /// 10.2 如果有dispatch到main_queue的block，执行block。
            else if (msg_is_dispatch) 
                __CFRUNLOOP_IS_SERVICING_THE_MAIN_DISPATCH_QUEUE__(msg);
             

            /// 10.3 如果一个 Source1 (基于port) 发出事件了，处理这个事件
            else 
                CFRunLoopSourceRef source1 = __CFRunLoopModeFindSourceForMachPort(runloop, currentMode, livePort);
                sourceHandledThisLoop = __CFRunLoopDoSource1(runloop, currentMode, source1, msg);
                if (sourceHandledThisLoop) 
                    mach_msg(reply, MACH_SEND_MSG, reply);
                
            

            /// 执行加入到Loop的block
            __CFRunLoopDoBlocks(runloop, currentMode);


            if (sourceHandledThisLoop && stopAfterHandle) 
                /// 进入loop时参数说处理完事件就返回。
                retVal = kCFRunLoopRunHandledSource;
             else if (timeout) 
                /// 超出传入参数标记的超时时间了
                retVal = kCFRunLoopRunTimedOut;
             else if (__CFRunLoopIsStopped(runloop)) 
                /// 被外部调用者强制停止了
                retVal = kCFRunLoopRunStopped;
             else if (__CFRunLoopModeIsEmpty(runloop, currentMode)) 
                /// source/timer/observer一个都没有了
                retVal = kCFRunLoopRunFinished;
            

            /// 如果没超时，mode里没空，loop也没被停止，那继续loop。
         while (retVal == 0);
    

    /// 11. 通知 Observers: RunLoop 即将退出。
    __CFRunLoopDoObservers(rl, currentMode, kCFRunLoopExit);

代码一长串，但是标了注释，应该大致能看明白，大概讲一下：

  • 函数的主体是一个do, while循环，用一个变量retVal，来控制循环的执行。默认为0，无限循环。

  • 刚进入循环1，2，3，4，5在做一件事，就是检查是否有事件需要处理，如果有的话，直接跳到9去处理事件。

  • 处理完事件之后，到第10行，会去判断4种是否应该跳出循环的情况，给出变量retVal赋一个不为0的值，来跳出循环。

  • 如果走到6，则判断没有事情做，那么runloop就睡眠了，停在第7行，这一行类似sync这样的同步机制(其实不是，只是举个例子。。)，把程序阻塞在这一行，直到有消息返回值，才继续往下进行。这一阻塞操作是系统内核挂起来的，阻塞了当前的线程，当有消息返回时，因为当前线程是被阻塞的，系统内核会再开辟一条新的线程去返回这个消息。然后程序继续往下进行。

  • 走到第8、9，通知Observers，然后处理事件。

  • 到10，去判断是否退出循环的条件，如果满足条件退出循环，runloop结束。反之，又从新开始循环，从2开始。
    这就是一个完整的runloop处理事件的流程。

回到上述的例子这种模式下的runloop：

- (BOOL) runMode:(NSString *)mode beforeDate:(NSDate *)limitDate;

我们让线程执行了一个事件，结果执行完，runloop就退出了，原因是这样的：

if (sourceHandledThisLoop && stopAfterHandle) 
    /// 进入loop时参数处理完毕事件就返回
    retVal = kCFRunLoopHandledSource;
  • 这种形式开启的runloop， stopAfterHandle这个参数为YES，而sourceHandledThisLoop这个参数在如下代码中被赋值为YES：
/// 10.3 如果一个Source1（基于port）发出了事件，处理这个事件
else 
    CFRunLoopSourceRef source1 = __CFRunLoopModeFindSourceForMachPort(runloop, currentMode, livePort);
    sourceHandledThisLoop = __CFRunLoopDoSource1(runloop, currentMode, source1, msg);
    if (sourceHandledThisLoop) 
        mach_msg(reply, MACH_SEND_MSG, reply);

所以在这里我们触发了事件之后，runloop被退出了，这个时候我们也明白了为什么timer并不会导致runloop的退出。

接下来我们分析一下Core Foundation中运行的runloop的借口：

/// 运行CFRunLoopRef
void CFRunLoopRun()
/// 运行CFRunLoopRef： 参数为运行模式、时间和是否在处理Input Source后退出标示，返回值是exit原因
SInt32 CFRunLoopRunInMode (mode, seconds, returnAfterSourceHandled);
/// 停止运行 CFRunLoopRef
void CFRunLoopStop(CFRunLoopRef rl);
/// 唤醒 CFRunLoopRef
void CFRunLoopWakeUp(CFRunLoopRef rl);

First

void CFRunLoopRun();

  • 运行在默认的kCFRunLoopDefaultMode模式下，知道CFRunLoopStop接口调用停止这个RunLoop，或者RunLoop的所有事件源被删除。

  • NSRunLoop是基于CFRunLoop来封装的，NSRunLoop是线程不安全的，而CFRunLoop是线程安全的。

  • 在这里我们可以看到和上面NSRunLoop有一个直观的区别是：CFRunLoop能直接停止掉所有的CFRunLoop运行起来的runloop，其实之前讲到的：

- (BOOL)runMode:(NSString *)mode beforeDate:(NSDate *)limitDate;

这种方式运行起来的runloop也能用CFRunLoopStop 停止掉的，原因是它完全是基于下面这种方式封装的：

SInt32 CFRunLoopRunInMode(mode, seconds, returnAfterSourceHandled);

可以看到参数几乎一模一样，前者默认returnAfterSourceHandled参数为YES，当触发一个非timer事件后，runloop就终止了。

  • 这里比较简单，就不举例赘述了。

Second

SInt32 CFRunLoopRunInMode(mode, seconds, returnAfterSourceHandled);

  • 这里有3个参数，1个返回值

  • 其中第一个参数是指RunLoop运行的模式(例如kCFRunLoopDefaultMode或者kCFRunLoopCommonModes），第二个参数是运行事件，第三个参数是是否在处理事件后让Run Loop退出返回，NSRunLoop的第三种开启runloop的方法，综上所述，我们知道，实际上就是设置stopAfterHande这个参数为YES

  • 关于返回值，我们知道调用runloop运行，代码是停在这一行不返回的，当返回的时候runloop就结束了，所有这个返回值就是runloop结束原因的返回，为一个枚举值，具体原因如下：

enum 
    kCFRunLoopRunFinished = 1, // Run Loop结束，没有Timer或者其他Input Source
    kCFRunLoopRunStopped = 2, // Run Loop被停止，使用CFRunLoopStop停止Run Loop
    kCFRunLoopRunTimedOut = 3, // Run Loop超时
    kCFRunLoopRunHandledSource = 4, // Run Loop处理完事件，注意Timer事件的触发是不会让Run Loop退出返回的，即使CFRunLoopRunInMode的第三个参数是YES也不行

看到这，我们发现我们忽略了NSRunLoop第三种开启方式的返回值。
- (Bool)runMode:(NSString *)mode beforeDate:(NSDate *)limitDate;
它其实就是基于CFRunLoopRunInMode封装的，它的返回值为一个Bool值，如果是PerformSelector *事件或者其他Input Source事件触发处理后，Run Loop会退出返回YES， 其他返回NO。

举个例子：

- (void)testDemo2

    dispatch_async(dispatch_get_global_queue(0, 0), ^

        NSLog(@"starting thread.......");
        NSTimer *timer = [NSTimer timerWithTimeInterval:1 target:self selector:@selector(doTimerTask1:) userInfo:remotePort repeats:YES];
        [[NSRunLoop currentRunLoop] addTimer:timer forMode:NSDefaultRunLoopMode];

        //最后一个参数，是否处理完事件返回,结束runLoop
        SInt32 result = CFRunLoopRunInMode(kCFRunLoopDefaultMode, 100, YES);
        /*
         kCFRunLoopRunFinished = 1, //Run Loop结束，没有Timer或者其他Input Source
         kCFRunLoopRunStopped = 2, //Run Loop被停止，使用CFRunLoopStop停止Run Loop
         kCFRunLoopRunTimedOut = 3, //Run Loop超时
         kCFRunLoopRunHandledSource = 4 Run Loop处理完事件，注意Timer事件的触发是不会让Run Loop退出返回的，即使CFRunLoopRunInMode的第三个参数是YES也不行
         */
        switch (result) 
            case kCFRunLoopRunFinished:
                NSLog(@"kCFRunLoopRunFinished");

                break;
            case kCFRunLoopRunStopped:
                NSLog(@"kCFRunLoopRunStopped");

            case kCFRunLoopRunTimedOut:
                NSLog(@"kCFRunLoopRunTimedOut");

            case kCFRunLoopRunHandledSource:
                NSLog(@"kCFRunLoopRunHandledSource");
            default:
                break;
        

        NSLog(@"end thread.......");

    );



- (void)doTimerTask1:(NSTimer *)timer


    count++;
    if (count == 2) 
        [timer invalidate];
    
    NSLog(@"do timer task count:%d",count);

输出结果如下：

2016-11-23 09:19:28.342 TestRunloop3[88598:1971412] starting thread.......
2016-11-23 09:19:29.347 TestRunloop3[88598:1971412] do timer task count:1
2016-11-23 09:19:30.345 TestRunloop3[88598:1971412] do timer task count:2
2016-11-23 09:19:30.348 TestRunloop3[88598:1971412] kCFRunLoopRunFinished
2016-11-23 09:19:30.348 TestRunloop3[88598:1971412] end thread.......
  • 很清楚的可以看到，当timer被置无效的时候，runloop里面没有了任何事件源，所以退出了，退出原因为：kCFRunLoopRunFinished，线程也就结束了。

总结一下：

  • runloop的运行方法一共有5种：包括NSRunLoop的3种，CFRunLoop的2种；
    而取消的方式一共为3种：
    1）移除掉runloop种的所有事件源（timer和source）。
    2）设置一个超时时间。
    3）只要CFRunLoop运行起来就可以用：void CFRunLoopStop(CFRunLoopRef rl); 去停止。
    除此之外用 NSRunLoop下面这个方法也能使用void CFRunLoopStop(CFRunLoopRef rl); 停止：
[NSRunLoop currentRunLoop] runMode:<#(nonull NSRunLoopMode)#> beforeDate:<#(nonull NSDate)#>
  • 实现过程中，可以根据需求，我们可以设置一个自己的Bool值，来控制runloop的开始于停止，类似下面这样：
while(!cancel) 
    CFRunLoopRunInMode(kCFRunLoopDefaultMode, 1, YES);

  • 每次runloop只运行1秒就停止，然后开始下一次runloop。

  • 这里最后一个参数设置为YES，当有非timer事件进来，也会立即开始下一次runloop。

  • 当然每次进来我们都可以去修改Mode的值，这样我们呢可以让runloop每次都运行在不同的模式下。

  • 当我们不需要runloop的时候，可以直接将cancel设置为YES即可。

当然，这里只是提供一个思路，具体有需求，可以根据实际需要。

基于runloop的线程通信

首先明确一个概念，线程间的通信(不仅限于通信，几乎所有iOS事件都是如此)，实际上是各种输入源，触发runloop去处理对应的事件，所以我们先来讲讲输入源：
输入源异步的发送消息给你的线程。事件来源取决于输入源的种类：

  • 基于端口的输入源和自定义输入源。基于端口的输入源监听程序相应的端口。自定义输入源则监听自定义的事件源。

当你创建输入源，你需要将其分配给run loop中的一个或多个模式。模式只会在特定事件影响监听的源。大多数情况下，runloop运行在默认模式下，但是你也可以使其运行在自定义模式。若其一源在当前模式下不被监听，那么任何其生成的消息只在run loop运行在其关联的模式下才会被传递。

1）基于端口的输入源：
在runloop中，被定义名为source1。Cocoa和Core Foundation内置支持使用端口相关的对象和函数来创建的基于端口对象，并使用NSPort的方法吧端口添加到runloop。端口对象会自己处理创建和配置输入源。

在Core Foundation，你必须人工创建端口和它的run loop源。在两种情况下，你都可以使用端口相关的函数(CFMachPortRef, CFMessagePortRef, CFSockerRef)来创建合适的对象。

这里用Cocoa里的举个例子，Cocoa里用来线程传值得NSMachPort，它的父类是NSPort。
首先我们看下面：

NSPort *port1 = [[NSPort alloc]init];
NSPort *port2 = [[NSMachPort alloc]init];
NSPort *port3 = [NSPort port];
NSPort *port4 = [NSMachPort port];

我们可以打断点看到如下：

* 发现我们怎么创建，都返回给我们的是NSMachPort的实例，这应该是NSProt内部做了一个消息的转发，这就有点像是一个抽象类，它本身只是定义一些公有属性和方法，然后利用集成它的子类去实现(只是我个人猜测。。)

继续看我们写的一个利用NSMachPort来线程通信的实例：

- (void)testDemo3

    //声明两个端口   随便怎么写创建方法，返回的总是一个NSMachPort实例
    NSMachPort *mainPort = [[NSMachPort alloc]init];
    NSPort *threadPort = [NSMachPort port];
    //设置线程的端口的代理回调为自己
    threadPort.delegate = self;

    //给主线程runloop加一个端口
    [[NSRunLoop currentRunLoop]addPort:mainPort forMode:NSDefaultRunLoopMode];

    dispatch_async(dispatch_get_global_queue(0, 0), ^

        //添加一个Port
        [[NSRunLoop currentRunLoop]addPort:threadPort forMode:NSDefaultRunLoopMode];
        [[NSRunLoop currentRunLoop]runMode:NSDefaultRunLoopMode beforeDate:[NSDate distantFuture]];

    );

    NSString *s1 = @"hello";

    NSData *data = [s1 dataUsingEncoding:NSUTF8StringEncoding];

    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(2 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^
        NSMutableArray *array = [NSMutableArray arrayWithArray:@[mainPort,data]];
        //过2秒向threadPort发送一条消息，第一个参数：发送时间。msgid 消息标识。
        //components，发送消息附带参数。reserved：为头部预留的字节数（从官方文档上看到的，猜测可能是类似请求头的东西...）
        [threadPort sendBeforeDate:[NSDate date] msgid:1000 components:array from:mainPort reserved:0];

    );



//这个NSMachPort收到消息的回调，注意这个参数，可以先给一个id。如果用文档里的NSPortMessage会发现无法取值
- (void)handlePortMessage:(id)message


    NSLog(@"收到消息了，线程为：%@",[NSThread currentThread]);

    //只能用KVC的方式取值
    NSArray *array = [message valueForKeyPath:@"components"];

    NSData *data =  array[1];
    NSString *s1 = [[NSString alloc]initWithData:data encoding:NSUTF8StringEncoding];
    NSLog(@"%@",s1);

//    NSMachPort *localPort = [message valueForKeyPath:@"localPort"];
//    NSMachPort *remotePort = [message valueForKeyPath:@"remotePort"];

打印如下：

2016-11-23 16:50:20.604 TestRunloop3[1322:120162] 收到消息了，线程为：<NSThread: 0x60800026d700>number = 3, name = (null)
2016-11-23 16:50:26.551 TestRunloop3[1322:120162] hello

  • 我们跨越线程，确实从主线程往另外一个线程发送了消息。

  • 这里我们要注意几个点：
    1）- (void)handlePortMessage:(id)message 这里这个代理的参数，从.h中去复制过来的为NSPortMessage类型的一个对象，但是我们发现苹果只是在.h中@class过来，我们无法调用它的任何方法。所有我们用id声明，然后通过kvc去取它的属性。
    2）关于下面这个传值类型的问题：
    NSMutableArray *array = [NSMutableArray arrayWithArray: @[mainPort, data]];
    在此我困惑了好一会儿。。之前我是往数组里添加的是String或者其他类型的对象，但是发现参数传过去之后，变成了nil。于是查了半天资料，依然没有结果。于是翻看官方文档，终于在方法描述里看到了(其实很醒目，然后作者英文水平有限。。)

    The components array consists of a series of instances
    of some subclass of NSData, and instances of some
    subclass of NSPort; since one subclass of NSPort does
    not necessarily know how to transport an instance of
    another subclass of NSPort (or could do it even if it
    knew about the other subclass), all of the instances
    of NSPort in the components array and the ‘receivePort’
    argument MUST be of the same subclass of NSPort that
    receives this message. If multiple DO transports are
    being used in the same program, this requires some care.

从这段描述中我们可以看出，这个传参数组里面只能装两种类型的数据，一种是NSPort的子类，一种是NSData的子类。所有我们如果要用这种方式传值必须得先把数据转成NSData类型的才行。

2）Cocoa 执行Selector的源

  • 除了基于端口的源，Cocoa定义了自定义输入源，允许你在任何线程执行selector。它被称为source0，和基于端口的源一样，执行selector请求会在目标线程上序列化，减缓许多在线程上允许多个方法容易引起的同步问题。不像基于源的端口，一个selector执行完后会自动从run loop里面移除
[self performSelectorOnMainThread:<#(nonnull SEL)#> withObject:<#(nullable id)#> waitUntilDone:<#(BOOL)#>]
[self performSelectorOnMainThread:<#(nonnull SEL)#> withObject:<#(nullable id)#> waitUntilDone:<#(BOOL)#> modes:<#(nullable NSArray<NSString *> *)#>]

[self performSelector:<#(nonnull SEL)#> onThread:<#(nonnull NSThread *)#> withObject:<#(nullable id)#> waitUntilDone:<#(BOOL)#>]
[self performSelector:<#(nonnull SEL)#> onThread:<#(nonnull NSThread *)#> withObject:<#(nullable id)#> waitUntilDone:<#(BOOL)#> modes:<#(nullable NSArray<NSString *> *)#>]

  • 这四个方法很类似，一个是在主线程去掉，一个可以指定一个线程。然后一个带Mode，一个不带。

  • 大概讲一下 waitUntilDone这个参数，顾名思义，就是是否等到结束。
    1）如果这个值设为YES，那么就需要等到这个方法执行完，线程才能继续往下去执行。它会阻塞提交的线程。
    2）如果为NO的话，这个调用的方法会异步的实行，不会阻塞提交的线程。
    3）自定义输入源：

  • 为了自定义输入源，必须使用Core Foundation里面的CGRunLoopSourceRef类型相关的函数来创建。你可以使用回调函数来配置自定义输入源。CoreFoundation会在配置源的不同地方调用回调函数，处理输入时间，在源从runloop移除的时候清理它。除了定义在事件到达时自定义输入源的行为，你也必须定义消息传递机制。源的这部分运行在单独的线程里面，并负责在数据等待处理的时候将数据传递给源并通知它处理数据。消息传递机制的定义取决于你，但是最好不要过于复杂。
    创建自定义的输入源包括定义下面内容：
    1.输入源要处理的信息；
    2.使感兴趣的客户端知道如何和输入源交互的调度历程；
    3.处理其他任何客户端发送请求的历程；
    4.使输入源失效的取消历程。

  • 由于创建输入源来处理自定义消息，实际配置选是灵活的。调度历程，处理历程和取消历程都是创建自定义输入源的关键历程。二输入源其他的大部分行为都发生在这些历程的外部。比如，由于你决定数据传输到输入源的机制，还有输入源的其他线程的通信机制也是由你决定。

下图中，程序的主线程维护了一个输入源的引用，输入源所需的自定义命令缓冲区和输入源所在的runloop。当主线程有任务需要分发给工作线程时候，主线程会给命令缓冲区发送命令和必须的信息来通知工作线程开始执行任务.(因为主线程和输入源所在工作线程都是可以访问命令缓冲区的，因此这些方法必须是同步的)，一旦命令发送出去，主线程会通知输入源并唤醒工作线程的runloop。而一收到唤醒命令，runloop会调用输入源的处理程序，由它来执行命令缓冲区的响应命令。

这样一来，我们来写一个实例来讲讲自定义的输入源(自定义的输入源，只有用CF来实现)：

CFRunLoopRef _runLoopRef;
CFRunLoopSourceRef _source;
CFRunLoopSourceContext _source_context;

首先我们声明3个成员变量，这是我们自定义输入源所需要的3个参数。具体我们举例之后再说：

- (void)testDemo4

    dispatch_async(dispatch_get_global_queue(0, 0), ^

        NSLog(@"starting thread.......");

        _runLoopRef = CFRunLoopGetCurrent();
        //初始化_source_context。
        bzero(&_source_context, sizeof(_source_context));
        //这里创建了一个基于事件的源，绑定了一个函数
        _source_context.perform = fire;
        //参数
        _source_context.info = "hello";
        //创建一个source
        _source = CFRunLoopSourceCreate(NULL, 0, &_source_context);
        //将source添加到当前RunLoop中去
        CFRunLoopAddSource(_runLoopRef, _source, kCFRunLoopDefaultMode);

        //开启runloop 第三个参数设置为YES，执行完一次事件后返回
        CFRunLoopRunInMode(kCFRunLoopDefaultMode, 9999999, YES);

        NSLog(@"end thread.......");
    );


    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(2 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^

        if (CFRunLoopIsWaiting(_runLoopRef)) 
            NSLog(@"RunLoop 正在等待事件输入");
            //添加输入事件
            CFRunLoopSourceSignal(_source);
            //唤醒线程，线程唤醒后发现由事件需要处理，于是立即处理事件
            CFRunLoopWakeUp(_runLoopRef);
        else 
            NSLog(@"RunLoop 正在处理事件");
            //添加输入事件，当前正在处理一个事件，当前事件处理完成后，立即处理当前新输入的事件
            CFRunLoopSourceSignal(_source);
        
    );



//此输入源需要处理的后台事件
static void fire(void* info)

    NSLog(@"我现在正在处理后台任务");

    printf("%s",info);

输出结果如下：

2016-11-24 10:42:24.045 TestRunloop3[4683:238183] starting thread.......
2016-11-24 10:42:26.045 TestRunloop3[4683:238082] RunLoop 正在等待事件输入 
2016-11-24 10:42:31.663 TestRunloop3[4683:238183] 我现在正在处理后台任务
hello
2016-11-24 10:42:31.663 TestRunloop3[4683:238183] end thread.......

  • 例中可见我们创建一个自定义的输入源，绑定了一个函数，一个参数，并且这个输入源，实现了线程间的通信.

  • 大概说一下:

    a)CFRunLoopRef _runLoopRef;CF的runLoop。
    b）CFRunLoopSourceContext _source_context; 注意到例中用了一个C函数bzero(&_source_context, sizeof(_source_context)); 来初始化。其实它的本质是一个结构体：

typedef struct 
  CFIndex version;
  void *  info;
  const void *(*retain)(const void *info);
  void    (*release)(const void *info);
  CFStringRef (*copyDescription)(const void *info);
  Boolean (*equal)(const void *info1, const void *info2);
  CFHashCode  (*hash)(const void *info);
  void    (*schedule)(void *info, CFRunLoopRef rl, CFRunLoopMode mode);
  void    (*cancel)(void *info, CFRunLoopRef rl, CFRunLoopMode mode);
  void    (*perform)(void *info);
 CFRunLoopSourceContext;