多线程 – 反应扩展OnNext

发布时间：2020-12-14 05:37:26 所属栏目：Java 来源：网络整理

导读：使用RX主题,是否可以线程安全地从多个线程调用OnNext()？所以序列可以从多个来源生成. 用合并做同样的事情吗？解决方法 Rx合同要求通知是连续的,对于多个操作符来说是一个逻辑上的必要条件.也就是说,您可以使用可用的Synchronize方法来获取此行为. var sub

使用RX主题,是否可以线程安全地从多个线程调用OnNext()？

所以序列可以从多个来源生成.

用合并做同样的事情吗？

解决方法

Rx合同要求通知是连续的,对于多个操作符来说是一个逻辑上的必要条件.也就是说,您可以使用可用的Synchronize方法来获取此行为.

var subject = new Subject<int>();
        var syncedSubject = Subject.Synchronize(subject);

您现在可以对syncedSubject进行并发调用.
对于必须同步的观察者,您还可以使用：

var observer = Observer.Create<Unit>(...);
        var syncedObserver = Observer.Synchronize(observer);

测试：

Func<int,Action> onNext = i => () => syncedSubject.OnNext(i);
        Parallel.Invoke
        (
            onNext(1),onNext(2),onNext(3),onNext(4)
        );

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!