RACScheduler
文章系列
《ReactiveCocoa 概述》
《RACSignal》
《RACDisposable》
《RACSubject、RACReplaySubject(内附冷信号和热信号的区别)》
《集合RACTuple、RACSequence》
《RAC 中的通知、代理、KVO, 基本事件、方法的监听》
《rac_liftSelector》
《RACMulticastConnection》
《RACCommand》
《RAC - 核心方法bind》
《RAC - 定时器》
《RACScheduler》
《RAC - 点击获取验证码 demo》
《RAC - 映射(Map & flattenMap)》
《RAC信号操作解释合集》
《RAC - 信号的生命周期》
首先先理解四个名词的概念, 便于后续的理解.
- 同步:
顺序执行,执行完一个再执行下一个,需要等待、协调运行.- 异步:
是彼此独立,在等待某事件的过程中继续做自己的事,不需要等待这一事件完成后再工作.- 并发:
单核cpu 同时调度不同的线程.- 并行:
针对多核处理器而言, 进程不仅可以交替执行,而且可以重叠执行, 即每一核单独处理单独的线程.
1. RACScheduler 的定义
通俗来讲, RACScheduler 就是iOS 开发中的多线程, 且底层是用GCD封装的.
2. RACScheduler 的类方法
-
currentScheduler: 获取当前线程调度器.
在线程字典中根据@"RACSchedulerCurrentSchedulerKey"这个key 来取出对应的RACScheduler.
如果是在主线程上，就返回mainThreadScheduler.
如果既不在主线程上，线程字典里面也找不到对应key值对应的value，那么就返回nil.
NSLog(@"当前线程: %@", [RACScheduler currentScheduler]);
打印结果: 当前线程: <RACTargetQueueScheduler: 0x6000015420a0> org.reactivecocoa.ReactiveObjC.RACScheduler.mainThreadScheduler
-
mainThreadScheduler: 获取主线程调度器.
注:单例
[[RACScheduler mainThreadScheduler] schedule:^{
NSLog(@"当前线程: %@", [RACScheduler currentScheduler]);
}];
打印结果:当前线程: <RACTargetQueueScheduler: 0x600003a9d2c0> org.reactivecocoa.ReactiveObjC.RACScheduler.mainThreadScheduler
-
scheduler: 这是一个异步线程，不会对主线程造成堵塞，异步执行.
注: 非单例, 每调用一次, 都会生成不同的scheduler 对象, 互不相同, 互不干扰.
[[RACScheduler scheduler] schedule:^{
NSLog(@"当前线程: %@", [RACScheduler currentScheduler]);
}];
打印结果: 当前线程: <RACTargetQueueScheduler: 0x600001555ec0> org.reactivecocoa.ReactiveObjC.RACScheduler.backgroundScheduler
- immediateScheduler ，立即执行的线程，其实就是在主线程执行的.
注:单例
[[RACScheduler immediateScheduler] schedule:^{
NSLog(@"当前线程: %@", [RACScheduler currentScheduler]);
}];
打印结果: 当前线程: <RACTargetQueueScheduler: 0x6000037cdbc0> org.reactivecocoa.ReactiveObjC.RACScheduler.mainThreadScheduler
注:
慎用, immediateScheduler 作用就是在当前线程立即执行当前给的代码块内容, 容易造成死锁!!!
3. RACScheduler 的优先级设置
首先对类方法scheduler做一个补充
+ (RACScheduler *)scheduler;
+ (RACScheduler *)schedulerWithPriority:(RACSchedulerPriority)priority;
+ (RACScheduler *)schedulerWithPriority:(RACSchedulerPriority)priority name:(NSString *)name;
↓三个方法的本质是相同的, 点击看下实现, 就明白了↓
// 创建出来的queue的优先级是默认的，名字也是默认的
+ (instancetype)scheduler {
return [self schedulerWithPriority:RACSchedulerPriorityDefault];
}
// 方法只能执行优先级，名字为默认的
+ (instancetype)schedulerWithPriority:(RACSchedulerPriority)priority {
return [self schedulerWithPriority:priority name:@"com.ReactiveCocoa.RACScheduler.backgroundScheduler"];
}
// 方法可以指定线程的优先级和名字
+ (instancetype)schedulerWithPriority:(RACSchedulerPriority)priority name:(NSString *)name {
return [[RACTargetQueueScheduler alloc] initWithName:name targetQueue:dispatch_get_global_queue(priority, 0)];
}
RACScheduler中的优先级，这里只封装了4种
typedef enum : long {
RACSchedulerPriorityHigh = DISPATCH_QUEUE_PRIORITY_HIGH,
RACSchedulerPriorityDefault = DISPATCH_QUEUE_PRIORITY_DEFAULT,
RACSchedulerPriorityLow = DISPATCH_QUEUE_PRIORITY_LOW,
RACSchedulerPriorityBackground = DISPATCH_QUEUE_PRIORITY_BACKGROUND,
} RACSchedulerPriority;
示例代码
如何指定某个线程的优先级??? 使用方式3schedulerWithPriority: name:来设置, 即指定了线程, 也自定义了名称`
[[RACScheduler schedulerWithPriority:RACSchedulerPriorityHigh] schedule:^{
NSLog(@"当前线程: %@", [RACScheduler currentScheduler]);
}];
[[RACScheduler schedulerWithPriority:RACSchedulerPriorityHigh name:@"指定线程"] schedule:^{
NSLog(@"指定线程: %@",[RACScheduler currentScheduler]);
}];
打印结果:RAC 线程优先级设置
4. RACScheduler 常用的对象方法
注: schedule方法可以使用dispose 来取消任务, 本质是伪取消, 只是没有回调内部封装的block.
// 是为RACScheduler添加一个任务，入参是一个闭包
- (RACDisposable *)schedule:(void (^)(void))block;
// 是为RACScheduler添加一个定时任务，在date时间之后才执行任务
- (RACDisposable *)after:(NSDate *)date schedule:(void (^)(void))block;
// 是为RACScheduler添加一个延时执行的任务，延时delay时间之后才执行任务
- (RACDisposable *)afterDelay:(NSTimeInterval)delay schedule:(void (^)(void))block;
// 是为RACScheduler添加一个定时任务，在date时间之后才开始执行，然后每隔interval秒执行一次任务
- (RACDisposable *)after:(NSDate *)date repeatingEvery:(NSTimeInterval)interval withLeeway:(NSTimeInterval)leeway schedule:(void (^)(void))block;
注:一个Scheduler 保证串行执行; 但一个Scheduler 的任务不保证线程是同一个.
5.当RACSignal 遇到了RACScheduler
接下来分析当RACSignal 遇到了RACScheduler 时, 信号的发送和接收在不同线程中的订阅情况
RACSignal 订阅顺序回顾
RACSignal 订阅顺序
子线程订阅顺序分析
结论:
子线程订阅信号, 意味着整个订阅过程将在子线程中执行.子线程订阅
线程打印图
信号异步发送
结论:
信号异步发送, subscribeNext 的这个闭包, 一定在信号发送的线程执行.信号异步发送
333 在子线程中打印
信号在不同的scheduler 中发送
subscribeNext:的执行一定在对应的sendNext:的线程中执行.信号在不同的scheduler 中发送
1 在主线程中打印; 1.1在子线程中打印
订阅和发送都在不同的scheduler 中
didSubscribeblock 中的内容, 一定跟随订阅着subscriber同线程中执行.
subscribeNextblock 中的内容, 一定跟随信号发送sendNext同线程执行.订阅和发送都在不同的scheduler 中
订阅和发送都在不同的scheduler 中线程打印
发现问题 ???
- 订阅时机不确定
- 发送时机也不确定
所以, 得到的结果就不确定, 那怎么解决呢? 采用以下两种方式来处理:
- 订阅时机不确定 ->
subscribeOn: - 发送时机也不确定 ->
deliveOn
subscribeOn
负责使当前订阅者订阅后立即执行的
didSubscribeblock 执行在指定线程中.
- 84行使用
subscribeOn操作后, 直接使(67~79)行的didSubscribeblock 在84行指定的mainThreadScheduler中执行. 对应线程图中子线程中subscriber->主线程中didSubscribe的过程(灰色弧形箭头部分).
subscribeOn 示例
subscribeOn 操作后的订阅顺序
subscribeOn 总结:
- 能够保证didSubscribe block 在指定的scheduler 中执行.
- 不能保证sendNext、senfError、sendComplete 在那个scheduler 中执行.
deliveOn
能够保证
subscribeNext:在指定线程中执行.
- 下面的示例中, 56行的
subscribeNext:都是在53行指定的mainThreadScheduler主线程中执行的.deliveOn 示例
deliveOn 操作后的订阅顺序
.End
