美文网首页
runloop的使用

runloop的使用

作者: Nomo_C | 来源:发表于2018-05-02 21:06 被阅读0次

    ?xml version="1.0" encoding="UTF-8"?

    参考文章:深入理解RunLoop

    iOS刨根问底-深入理解RunLoop

    RunLoop的作用?

    保持程序运行。一般来说一个线程一次只能执行一次任务,执行完成后线程会退出。RunLoop能够保证线程执行完任务后不退出。

    处理App的各种事件(触摸事件、timer事件、seletor事件等)

    节省CPU资源,提高程序性能。线程休眠时不占用cpu资源,等待唤醒执行任务

    哪些可以唤醒runloop?

    Source

    当调用dispatch_async(dispatch_get_main_queue(),block)时

    Timer

    外表手动唤醒

    Runloop对象?

    Fundation框架

    NSRunLoop(基于CFRunloopRef的封装,面向对象的API,线程不安全)

    CoreFundation

    CFRunLoopRef,纯C函数的API,线程安全

    CFRunLoopRef 的代码是开源的,可以在这里 http://opensource.apple.com/tarballs/CF/CF-855.17.tar.gz 下载到整个CoreFoundation的源码。

    获取RunLoop对象

    苹果不允许直接创建RunLoop对象,但是提供了函数获取。

    RunLoop对象通过懒加载获取

    Fundation

    [NSRunloop currentRunLoop]  // 获取当前线程的RunLoop对象

    [NSRunloop mainRunLoop] // 获取主线程的RunLoop对象

    CoreFundation

    CFRunLoopGetCurrent(); // 获取当前线程的RunLoop对象

    CFRunLoopGetMain(); // 获取主线程的RunLoop对象

    RunLoop和线程的关系

    1.每一条线程都有唯一的一个与之对象的RunLoop对象

    2.主线程的RunLoop在启动的时候程序自动创建,子线程的RunLoop不会自动创建。

    3.Runloop在第一次获取时创建(懒加载),在线程结束时销毁

    RunLoop源码:

    CF_EXPORT CFRunLoopRef _CFRunLoopGet0(pthread_t t){

        if(pthread_equal(t,kNilPthreadT)){

    t = pthread_main_thread_np();

        }

    // 创建主线程中的runloop对象

    //__CFRunLoops 全局的Dictionary对象,key时p_thread,value是CFRunLoopRef。保存线程和Runloop,维护线程和Runloop的一一对应关系

        __CFSpinLock(&loopsLock);

        if(!__CFRunLoops){

    // 第一次进入时创建__CFRunLoops,并且为主线程创建一个RunLoop对象

            __CFSpinUnlock(&loopsLock);

    CFMutableDictionaryRef dict = CFDictionaryCreateMutable(kCFAllocatorSystemDefault,0,NULL,&kCFTypeDictionaryValueCallBacks);

    CFRunLoopRef mainLoop = __CFRunLoopCreate(pthread_main_thread_np());

    CFDictionarySetValue(dict,pthreadPointer(pthread_main_thread_np()),mainLoop);

    if(!OSAtomicCompareAndSwapPtrBarrier(NULL,dict,(void * volatile *)&__CFRunLoops)){

        CFRelease(dict);

    }

    CFRelease(mainLoop);

            __CFSpinLock(&loopsLock);

        }

        // 从全局的Dictio中获取runloop 

        CFRunLoopRef loop =(CFRunLoopRef)CFDictionaryGetValue(__CFRunLoops,pthreadPointer(t));

        __CFSpinUnlock(&loopsLock);

        if(!loop){

    CFRunLoopRef newLoop = __CFRunLoopCreate(t);

            __CFSpinLock(&loopsLock);

    loop =(CFRunLoopRef)CFDictionaryGetValue(__CFRunLoops,pthreadPointer(t));

    if(!loop){

        CFDictionarySetValue(__CFRunLoops,pthreadPointer(t),newLoop);

        loop = newLoop;

    }

            // don't release run loops inside the loopsLock,because CFRunLoopDeallocate may end up taking it

            __CFSpinUnlock(&loopsLock);

    CFRelease(newLoop);

        }

    // 注册一个回调,当线程销毁时,销毁RunLoop

      if(pthread_equal(t,pthread_self())){

            _CFSetTSD(__CFTSDKeyRunLoop,(void *)loop,NULL);

            if(0 == _CFGetTSD(__CFTSDKeyRunLoopCntr)){

                _CFSetTSD(__CFTSDKeyRunLoopCntr,(void *)(PTHREAD_DESTRUCTOR_ITERATIONS-1),(void(*)(void *))__CFFinalizeRunLoop);

            }

        }

        return loop;

    }

    从上面的代码中可以看出,线程和RunLoop对象时一一对应的关系,对应关系保存在一个Dictionary中。所以我们在子线程中使用[NSRunloop currentRunLoop]获取RunLoop对象时,如果Dictionary中没有,则会去创建一个,并保存在Dictionary中。如果不获取RunLoop对象则不会去创建。RunLoop的销毁是发生在线程结束时。

    RunLoop相关的类

    Core Fundation中RunLoop相关的类有5个

    CFRunLoopRef:RunLoop对象

    CFRunLoopModeRef:RunLoop所在的运行模式

    CFRunLoopSourceRef:事件源

    CFRunLoopTimerRef:定时器

    CFRunLoopObserverRef:观察者

    CFRunLoopModeRef

    CFRunLoopModeRef

    CFRunLoopModeRef类并没有对外暴露,只是通过CFRunLoopRef的接口进行了封装。他们的关系如下

    一个RunLoop包含若干个Mode,一个Mode中又包含若干个Source/Timer/Observer。每次调用RunLoop的主函数时,只能指定一个Mode,这个Mode就是CurrentMode。如果需要切换Mode,则必须退出RunLoop,再重新指定一个Mode进入。这样做是为了分隔开不同组中的Source/Timer/Observer,让其互不影响。

    CFRunLoopSourceRef

    CFRunLoopSourceRef是事件产生的地方。Source有两个版本:Source0和Source1

    Source0只包含一个回调(函数指针),它并不会主动触发事件。使用时,需要先调用CFRunLoopSourceSignal(source),将这个soucre标记为待处理,然后手动调用CFRunLoopSourceWakeUp(runloop)来唤醒RunLoop,让其处理这个事件。(点击按钮、点击屏幕)

    Source1包含一个mach_port和一个回调(函数指针),被用于用过内核和其他线程相互发送消息。这种Source能注定唤醒RunLoop的线程。硬件事件(触摸/锁屏/摇晃等)

    CFRunLoopTimerRef

    CFRunLoopTimerRef是基于时间的触发器,他和NSTimer时toll-free bridged的,可以混用。包含一个时间长度和一个回调(函数指针)。当其加入到RunLoop时,RunLoop会注册对应的时间点,当时间点到时,RunLoop会被唤醒以执行那个回调。

    CFRunLoopObserverRef

    CFRunLoopObserverRef是观察者,每一个Observer都包含了一个回调(函数指针),当RunLoop的状态发生变化时,观察者就能通过回调接收到这个变化。

    可以观测的点有一下几个:

    typedef CF_OPTIONS(CFOptionFlags, CFRunLoopActivity) {

        kCFRunLoopEntry         = (1UL << 0), // 即将进入Loop

        kCFRunLoopBeforeTimers  = (1UL << 1), // 即将处理 Timer

        kCFRunLoopBeforeSources = (1UL << 2), // 即将处理 Source

        kCFRunLoopBeforeWaiting = (1UL << 5), // 即将进入休眠

        kCFRunLoopAfterWaiting  = (1UL << 6), // 刚从休眠中唤醒

        kCFRunLoopExit          = (1UL << 7), // 即将退出Loop

    };

    上面的source、timer、observer被统称为mode item,一个item可以被加入多个mode中。单一个item被重复加入同一个mode时没有效果的。如果mode中一个item都没有,则RunLoop会直接退出,不进入循环。

    RunLoop的Mode

    CFRunLoop和CFRunLoopMode的结构大致如下

    struct __CFRunLoopMode {

        CFStringRef _name;            // Mode Name, 例如 @"kCFRunLoopDefaultMode"

        CFMutableSetRef _sources0;    // Set

        CFMutableSetRef _sources1;    // Set

        CFMutableArrayRef _observers; // Array

        CFMutableArrayRef _timers;    // Array

        ...

    };

    struct __CFRunLoop {

        CFMutableSetRef _commonModes;     // Set

        CFMutableSetRef _commonModeItems; // Set

        CFRunLoopModeRef _currentMode;    // Current Runloop Mode

        CFMutableSetRef _modes;           // Set

        ...

    };

    这里有个概念叫“CommonModes”:一个Mode可以将自己标记为“Common”属性(通过将其的ModeName添加到RunLoop的“CommonModes”中)。每当RunLoop的内容发生变化的时候都会自动将_commonModeItems里的Source/Observer/Timer同步到具有“Common”标记的所有Mode中。

    应用场景举例:主线程的RunLoop里有两个预置的Mode:kCFRunLoopDefaultMode和UITrackingRunLoopMode。这两个Mode都已经被标记为"Common"属性。DefaultMode是App平时所处的状态,TrackingRunLoopMode是追踪ScrollView滑动时的状态。当你创建一个Timer并加到DefaultMode时,Timer会得到重复回调,但此时滑动一个TableView时,RunLoop会将mode切换为TrackingRunLoopMode,这时Timer就不会被回调,并且也不会影响到滑动操作。

    有时你需要一个Timer,在两个Mode中都能得到回调,一种办法就是将这个Timer分别加入这两个Mode。还有一种方式,就是将Timer加入到顶层的RunLoop的"commonModeItems"中。"commonModeItems"被RunLoop自动更新到所有具有"Common"属性的Mode里去。

    CFRunLoop对外暴露的管理Model的接口只有下面两个:

    CFRunLoopAddCommonMode(CFRunLoopRef runloop, CFStringRef modeName);

    CFRunLoopRunInMode(CFStringRef modeName, ...);

    Mode暴露的管理mode item的接口有下面几个

    CFRunLoopAddSource(CFRunLoopRef rl, CFRunLoopSourceRef source, CFStringRef modeName);

    CFRunLoopAddObserver(CFRunLoopRef rl, CFRunLoopObserverRef observer, CFStringRef modeName);

    CFRunLoopAddTimer(CFRunLoopRef rl, CFRunLoopTimerRef timer, CFStringRef mode);

    CFRunLoopRemoveSource(CFRunLoopRef rl, CFRunLoopSourceRef source, CFStringRef modeName);

    CFRunLoopRemoveObserver(CFRunLoopRef rl, CFRunLoopObserverRef observer, CFStringRef modeName);

    CFRunLoopRemoveTimer(CFRunLoopRef rl, CFRunLoopTimerRef timer, CFStringRef mode);

    RunLoop的内部逻辑

    /// 用DefaultMode启动

    void CFRunLoopRun(void) {

        CFRunLoopRunSpecific(CFRunLoopGetCurrent(), kCFRunLoopDefaultMode, 1.0e10, false);

    }

    /// 用指定的Mode启动,允许设置RunLoop超时时间

    int CFRunLoopRunInMode(CFStringRef modeName, CFTimeInterval seconds, Boolean stopAfterHandle) {

        return CFRunLoopRunSpecific(CFRunLoopGetCurrent(), modeName, seconds, returnAfterSourceHandled);

    }

    /// 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;

                }

                /// 通知 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);

                /// 收到消息,处理消息。

                handle_msg:

                /// 9.1 如果一个 Timer 到时间了,触发这个Timer的回调。

                if (msg_is_timer) {

                    __CFRunLoopDoTimers(runloop, currentMode, mach_absolute_time())

                } 

                /// 9.2 如果有dispatch到main_queue的block,执行block。

                else if (msg_is_dispatch) {

                    __CFRUNLOOP_IS_SERVICING_THE_MAIN_DISPATCH_QUEUE__(msg);

                } 

                /// 9.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);

        }

        /// 10. 通知 Observers: RunLoop 即将退出。

        __CFRunLoopDoObservers(rl, currentMode, kCFRunLoopExit);

    }



    RunLoop的使用

    AutoreleasePool

    即将进入Runloop的时候创建AutoreleasePool。

    RunLoop即将进入休眠的时候释放并创建新的Runloop。

    即将退出Runloop的时候释放自动释放池。

    App启动后,苹果在主线程RunLoop里注册了两个Observer,其回调都是_wrapRunLoopWithAutoreleasePoolHandler()。

    第一个Observer监视的事件是Entry(即将进入Loop),其回调内会调用_objc_autoreleasePoolPush()创建自动释放池。其order是-2147483647,优先级最高,保证创建释放池发生在其他所有回调之前。

    第二个Observer监视了两个事件:BeforeWaiting(准备进入休眠)时调用_objc_autoreleasePoolPop()和_objc_autoreleasePoolPush()释放旧的池并创建新池;Exit(即将退出Loop)时调用_objc_autoreleasePoolPop()来释放自动释放池。这个Observer的order是2147483647,优先级最低,保证其释放池子发生在其他所有回调之后。

    在主线程执行的代码,通常是写在诸如事件回调、Timer回调内的。这些回调会被RunLoop创建好的AutoreleasePool环绕着,所以不会出现内存泄漏,开发者也不必显示创建Pool了。

    事件响应

    苹果注册了一个Source1(基于mach_port的)用来接收系统事件

    手势识别

    苹果注册了一个Observer监测BeforeWaiting(Loop即将进入休眠)事件,这个Observer的回调函数是_UIGestureRecognizerUpdateObserver(),其内部会获取所有刚被标记为待处理的GestureRecognizer,并执行GestureRecognizer的回调。

    界面更新

    当在操作UI时,比如改变了Frame、更新了UIView/CALayer的层次时,或者手动调用了UIView/CALayer的setNeedsLayout/setNeedsDisplay方法后,这个UIView/CALayer就被标记为待处理,并被提交到一个全局的容器去。

    苹果注册了一个Observer监听BeforeWaiting(即将进入休眠)和Exit(即将退出Loop)事件,回调去执行一个函数。这个函数会遍历所有待处理的UIView/UILayer以执行实际的绘制和调整,并更新UI

    定时器

    NSTimer其实就是CFRunLoopTimerRef,他们之间是toll-free bridged的。一个NSTimer注册到RunLoop后,RunLoop会为其重复的时间点注册好事件。例如10:00,10:10,10:20这几个时间点。RunLoop为了节省资源,并不会在非常准确的时间点回调这个Timer。Timer有个属性叫做Tolerance(宽容度),标示了当时间点到后,容许有多少最大误差。

    如果某个时间点被错过了,例如执行了一个很长的任务,则那个时间点的回调也会跳过去,不会延后执行。就比如等公交,如果10:10时我忙着玩手机错过了那个点的公交,那我只能等10:20这一趟了。

    CADisplayLink是一个和屏幕刷新率一致的定时器(但实际实现原理更复杂,和NSTimer并不一样,其内部实际是操作了一个Source)。如果在两次屏幕刷新之间执行了一个长任务,那其中就会有一帧被跳过去(和NSTimer相似),造成界面卡顿的感觉。在快速滑动TableView时,即使一帧的卡顿也会让用户有所察觉。Facebook开源的AsyncDisplayLink就是为了解决界面卡顿的问题,其内部也用到了RunLoop。

    PerformSelector

    当调用NSObject的performSelecter:afterDelay:后,实际上其内部会创建一个Timer并添加到当前线程的RunLoop中。所以如果当前线程没有RunLoop,则这个方法会失效。

    当调用performSelector:onThread:时,实际上其会创建一个Timer加到对应的线程去,同样的,如果对应线程没有RunLoop该方法也会失效。

    GCD

    当调用dispatch_async(dispatch_get_main_queue(),block)时,libDispatch会向主线程的RunLoop发送消息,RunLoop会被唤醒,并从消息中取得这个block,并在回调__CFRUNLOOP_IS_SERVICING_THE_MAIN_DISPATCH_QUEUE__()里执行这个block。但这个逻辑仅限于dispatch到主线程,dispatch到其他线程仍然是由libDispatch处理的。

    相关文章

      网友评论

          本文标题:runloop的使用

          本文链接:https://www.haomeiwen.com/subject/qvlpqftx.html