rxjava中的后台任务队列

Mig*_*eal 8 java android rx-java

是否可以使用rxjava实现后台任务队列?我需要随时添加任务的可能性,并且只能同时执行一个任务.我已经尝试过PublishSubject,但是当我将执行推送到新线程时,observeOn(Schedulers.newThread())它会启动多个任务.

更新: 是否可以使用rxjava实现生产者 - 消费者模式之类的东西?

Dav*_*ten 8

只需使用基于单个线程执行程序的调度程序:

Scheduler scheduler = Schedulers.from(Executors.newSingleThreadExecutor());
observable.observeOn(scheduler). ...
Run Code Online (Sandbox Code Playgroud)