您的位置：首页 > Web前端 > React

RAC中Multicast的实现原理分析

2016-08-27 16:08 477 查看

1. 为什么要用Multicast？

RACMulticastConnection类的注释如下：

/// A multicast connection encapsulates the idea of sharing one subscription to a
/// signal to many subscribers. This is most often needed if the subscription to
/// the underlying signal involves side-effects or shouldn't be called more than
/// once.


从注释中可以知道，Multicast的作用是让side effect代码只被执行一次。我们知道，普通Signal每次被subscribe，都会执行side effect代码。如果side effect代码性能开销很大并且重复执行结果相同，那么确保side effect代码只被执行一次就很有意义，Multicast就是做的这个事情。

2. Multicast是如何确保side effect代码只被执行一次？

为了解答这个问题，我们要知道为什么普通Signal每次被subscribe，都会执行side effect代码。

一般，我们会调用下面这个方法创建Signal，所有的side effect代码的都包含在didSubscribe这个Block中。

+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe;


Signal在被subscribe的时候会执行这个Block，源码如下（省略非关键代码）：

- (RACDisposable *)subscribe:(id<RACSubscriber>)subscriber {
、、、
RACDisposable *innerDisposable = self.didSubscribe(subscriber);
、、、
}


我们调用doNext、flatten、concat等Operation对Signal进行变换，内部多是创建一个新的Signal，这个新的Signal的didSubcribe中会subscirbe要变换的Signal。所以使用Operation对Signal进行变换得到的Signal，被subscribe的时候会一层一层向上去subscribe最原始的Signal，一层一层向上去执行didSubscribe Block，最终所有的side effect代码都会被执行。

那么Multicast是如何做到side effect仅被执行一次的？

注释是这么说的
A multicast connection encapsulates the idea of sharing one subscription to a signal to many subscribers.
。看源码可以知道，内部是利用RACSubject在中间转发消息，RACSubject（
_signal
）订阅真正的Signal（
sourceSignal
），外部Subscribers订阅RACSubject（
_signal
），如下图所示：



源码如下（省略非关键代码）:

- (RACDisposable *)connect {
BOOL shouldConnect = OSAtomicCompareAndSwap32Barrier(0, 1, &_hasConnected);

if (shouldConnect) {
self.serialDisposable.disposable = [self.sourceSignal subscribe:_signal];
}

return self.serialDisposable;
}

- (RACSignal *)autoconnect {
、、、
return [[RACSignal
createSignal:^(id<RACSubscriber> subscriber) {
、、、
RACDisposable *subscriptionDisposable = [self.signal subscribe:subscriber];
RACDisposable *connectionDisposable = [self connect];
、、、
}]
setNameWithFormat:@"[%@] -autoconnect", self.signal.name];
}


从上面源码还可以看出，autoconnect是lazy的，有外部订阅者订阅的时候，才调用connect方法，让subject订阅sourceSignal。

这里的关键是RACSubject，它既是sourceSignal的订阅者，也是外部subscribers的数据源。RACSubject会被订阅多次，而sourceSignal只会被订阅一次，它的didSubscribe Block只会被执行一次，只会产生一次副作用。
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 点击这里给我发消息
标签：  RAC IOS Multicast Reactive Cocoa
相关文章推荐
新的分享
章节导航