美文网首页
RunLoop与线程与GCD的关系

RunLoop与线程与GCD的关系

作者: 飘金 | 来源:发表于2017-06-10 14:31 被阅读0次

    首先,iOS 开发中能遇到两个线程对象: pthread_t 和 NSThread。过去苹果有份文档标明了 NSThread 只是 pthread_t 的封装,但那份文档已经失效了,现在它们也有可能都是直接包装自最底层的 mach thread。苹果并没有提供这两个对象相互转换的接口,但不管怎么样,可以肯定的是 pthread_t 和 NSThread 是一一对应的。比如,你可以通过 pthread_main_thread_np() 或 [NSThread mainThread] 来获取主线程;也可以通过 pthread_self() 或 [NSThread currentThread] 来获取当前线程。CFRunLoop 是基于 pthread 来管理的。

    苹果不允许直接创建 RunLoop,它只提供了两个自动获取的函数:CFRunLoopGetMain() 和 CFRunLoopGetCurrent()。 这两个函数内部的逻辑大概是下面这样:

    /// 全局的Dictionary,key 是 pthread_t, value 是 CFRunLoopRef
    static CFMutableDictionaryRef loopsDic;
    /// 访问 loopsDic 时的锁
    static CFSpinLock_t loopsLock;
    
    /// 获取一个 pthread 对应的 RunLoop。
    CFRunLoopRef _CFRunLoopGet(pthread_t thread) {
        OSSpinLockLock(&loopsLock);
        
        if (!loopsDic) {
            // 第一次进入时,初始化全局Dic,并先为主线程创建一个 RunLoop。
            loopsDic = CFDictionaryCreateMutable();
            CFRunLoopRef mainLoop = _CFRunLoopCreate();
            CFDictionarySetValue(loopsDic, pthread_main_thread_np(), mainLoop);
        }
        
        /// 直接从 Dictionary 里获取。
        CFRunLoopRef loop = CFDictionaryGetValue(loopsDic, thread));
        
        if (!loop) {
            /// 取不到时,创建一个
            loop = _CFRunLoopCreate();
            CFDictionarySetValue(loopsDic, thread, loop);
            /// 注册一个回调,当线程销毁时,顺便也销毁其对应的 RunLoop。
            _CFSetTSD(..., thread, loop, __CFFinalizeRunLoop);
        }
        
        OSSpinLockUnLock(&loopsLock);
        return loop;
    }
    
    CFRunLoopRef CFRunLoopGetMain() {
        return _CFRunLoopGet(pthread_main_thread_np());
    }
    
    CFRunLoopRef CFRunLoopGetCurrent() {
        return _CFRunLoopGet(pthread_self());
    }
    
    /// 全局的Dictionary,key 是 pthread_t, value 是 CFRunLoopRef
    static CFMutableDictionaryRef loopsDic;
    /// 访问 loopsDic 时的锁
    static CFSpinLock_t loopsLock;
     
    /// 获取一个 pthread 对应的 RunLoop。
    CFRunLoopRef _CFRunLoopGet(pthread_t thread) {
        OSSpinLockLock(&loopsLock);
        
        if (!loopsDic) {
            // 第一次进入时,初始化全局Dic,并先为主线程创建一个 RunLoop。
            loopsDic = CFDictionaryCreateMutable();
            CFRunLoopRef mainLoop = _CFRunLoopCreate();
            CFDictionarySetValue(loopsDic, pthread_main_thread_np(), mainLoop);
        }
        
        /// 直接从 Dictionary 里获取。
        CFRunLoopRef loop = CFDictionaryGetValue(loopsDic, thread));
        
        if (!loop) {
            /// 取不到时,创建一个
            loop = _CFRunLoopCreate();
            CFDictionarySetValue(loopsDic, thread, loop);
            /// 注册一个回调,当线程销毁时,顺便也销毁其对应的 RunLoop。
            _CFSetTSD(..., thread, loop, __CFFinalizeRunLoop);
        }
        
        OSSpinLockUnLock(&loopsLock);
        return loop;
    }
     
    CFRunLoopRef CFRunLoopGetMain() {
        return _CFRunLoopGet(pthread_main_thread_np());
    }
     
    CFRunLoopRef CFRunLoopGetCurrent() {
        return _CFRunLoopGet(pthread_self());
    }
    

    从上面的代码可以看出,线程和 RunLoop 之间是一一对应的,其关系是保存在一个全局的 Dictionary 里。线程刚创建时并没有 RunLoop,如果你不主动获取,那它一直都不会有。RunLoop 的创建是发生在第一次获取时,RunLoop 的销毁是发生在线程结束时。你只能在一个线程的内部获取其 RunLoop(主线程除外)。

    关于GCD

    实际上 RunLoop 底层也会用到 GCD 的东西,但同时 GCD 提供的某些接口也用到了 RunLoop, 例如 dispatch_async()。

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

    代码示例:

    #import "ViewController.h"
    #import "PJThread.h"
    
    @interface ViewController ()
    
    //创建一个NSRunLoop属性,用于在线程执行完后能在访问他的内容
    @property (nonatomic, strong)NSRunLoop *threadRunLoop;
    
    //GCD方式
    @property (nonatomic, strong)NSRunLoop *threadRunLoop2;
    
    @end
    
    @implementation ViewController
    
    - (void)viewDidLoad {
        [super viewDidLoad];
        
        __weak typeof(self) weakSelf = self;
        //PJThread为自定义的继承NSThread的线程,被销毁时会打印"线程销毁了!"
        PJThread *pjThread = [[PJThread alloc] initWithBlock:^{
            //线程刚创建时并没有 RunLoop,如果你不主动获取,那它一直都不会有。RunLoop 的创建是发生在第一次获取时,这边会创建一个与pjThread对应的线程.你只能在一个线程的内部获取其 RunLoop(主线程除外)
            weakSelf.threadRunLoop = [NSRunLoop currentRunLoop];
            //为了能让线程被销毁weakSelf.threadRunLoop就不循环执行(即不调用run)
            NSLog(@"在线程block内打印:%@",weakSelf.threadRunLoop);
        }];
        
        [pjThread start];
        
        //到这边时线程已经执行结束,被销毁,他所对应的runLoop也会被销毁
        NSLog(@"在线程执行后打印:%@",self.threadRunLoop);
        
        //和PJThread是一样的效果
        dispatch_async(dispatch_get_global_queue(0, 0), ^{
            weakSelf.threadRunLoop2 = [NSRunLoop currentRunLoop];
            //为了能让线程被销毁weakSelf.threadRunLoop2就不循环执行(即不调用run)
            NSLog(@"在dispatch_async block内打印:%@",weakSelf.threadRunLoop2);
        });
        
        NSLog(@"在线程dispatch_async执行后打印:%@",self.threadRunLoop2);
    }
    
    @end
    
    

    PJThread代码:

    #import "PJThread.h"
    
    @implementation PJThread
    
    - (void)dealloc{
        NSLog(@"线程销毁了!");
    }
    
    @end
    
    

    最终的打印效果:

    
    2017-06-10 14:35:37.966179 RunLoopTest[11826:3392880] 在线程执行后打印:(null)
    2017-06-10 14:35:37.966392 RunLoopTest[11826:3392880] 在线程dispatch_async执行后打印:(null)
    2017-06-10 14:35:37.967431 RunLoopTest[11826:3392903] 在dispatch_async block内打印:<CFRunLoop 0x17017d040 [0x1aa9abbb8]>{wakeup port = 0x5f03, stopped = false, ignoreWakeUps = true, 
    current mode = (none),
    common modes = <CFBasicHash 0x1700520f0 [0x1aa9abbb8]>{type = mutable set, count = 1,
    entries =>
        2 : <CFString 0x1a486d470 [0x1aa9abbb8]>{contents = "kCFRunLoopDefaultMode"}
    }
    ,
    common mode items = (null),
    modes = <CFBasicHash 0x170052510 [0x1aa9abbb8]>{type = mutable set, count = 1,
    entries =>
        2 : <CFRunLoopMode 0x170187df0 [0x1aa9abbb8]>{name = kCFRunLoopDefaultMode, port set = 0x6003, queue = 0x17017d100, source = 0x1701c6bd0 (not fired), timer port = 0x6203, 
        sources0 = (null),
        sources1 = (null),
        observers = (null),
        timers = (null),
        currently 518769338 (12655688486437) / soft deadline in: 7.68613809e+11 sec (@ -1) / hard deadline in: 7.68613809e+11 sec (@ -1)
    },
    
    }
    }
    2017-06-10 14:35:37.967823 RunLoopTest[11826:3392920] 在线程block内打印:<CFRunLoop 0x17417c740 [0x1aa9abbb8]>{wakeup port = 0x5c03, stopped = false, ignoreWakeUps = true, 
    current mode = (none),
    common modes = <CFBasicHash 0x1740533e0 [0x1aa9abbb8]>{type = mutable set, count = 1,
    entries =>
        2 : <CFString 0x1a486d470 [0x1aa9abbb8]>{contents = "kCFRunLoopDefaultMode"}
    }
    ,
    common mode items = (null),
    modes = <CFBasicHash 0x1740532f0 [0x1aa9abbb8]>{type = mutable set, count = 1,
    entries =>
        2 : <CFRunLoopMode 0x174187c50 [0x1aa9abbb8]>{name = kCFRunLoopDefaultMode, port set = 0x5d03, queue = 0x17417c800, source = 0x1741c6630 (not fired), timer port = 0x6303, 
        sources0 = (null),
        sources1 = (null),
        observers = (null),
        timers = (null),
        currently 518769338 (12655688502251) / soft deadline in: 7.68613809e+11 sec (@ -1) / hard deadline in: 7.68613809e+11 sec (@ -1)
    },
    
    }
    }
    2017-06-10 14:35:37.970469 RunLoopTest[11826:3392920] 线程销毁了!
    
    
    

    相关文章

      网友评论

          本文标题:RunLoop与线程与GCD的关系

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