我希望用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()
获得新的单线程执行器
发布于 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()
。
https://stackoverflow.com/questions/42394848
复制相似问题