RxJava中单线程ExecutorService的等价物是什么？
RxJava中单线程ExecutorService的等价物是什么？
提问于 2017-02-22 22:52:41
我希望用RxJava代替我的单线程ExecutorService
private ExecutorService executor = Executors.newSingleThreadExecutor();
executor.submit(/* ... */);我想知道使用RxJava的等效设置是什么？到目前为止，我尝试了以下几点：
private Subject<MyClass> subject = PublishSubject.create()
subject.toFlowable(MISSING)
.observeOn(Schedulers.single())
.subscribeOn(Schedulers.single())
.subscribe(obj -> {
// handle on next
});这是等同于我上面的ExecutorService设置还是不同？我是否可以通过Schedulers.single()获得新的单线程执行器
回答 1
Stack Overflow用户
发布于 2017-02-22 23:01:55
取决于ExecutorService的生命周期。如果它是应用程序范围的，并且绑定到它的整个生命周期，那么Schedulers.single()就等同于它。
如果您有多个单线程ExecutorService实例，并且希望在不同但特定的线程上处理您的flow stages，那么就不要。这里有两个选择：
1)如果唯一的要求是在不同的线程上，但在每个独立的订阅者上可能会发生变化，您可以使用io()或computation()
2)如果您想对每个独立订阅者的阶段进行线程限制，您可以在ExecutorService中使用多个Schedulers.from(Executor)，也可以使用RxJavaPlugins.createNewSingleScheduler(ThreadFactory)。如果你想依赖内部组件，你也可以直接使用new SingleScheduler()。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/42394848
复制相关文章
相似问题