RxJava中AndroidSchedulers.mainThread()的替代方法是什么？

概述RxAava中是否有与RxAndroid中的AndroidSchedulers.mainThread()同义的RxJava中的Schedulerapi.因此,如果我在新线程上安排任务,并且我想在Java主线程上观察它,我该怎么做？编辑下面是一个示例RxSubscription,在system.in注释时,当Observable.interval在一个单独的线程上运行时,Mai

RxAava中是否有与RxAndroid中的AndroidSchedulers.mainThread()同义的RxJava中的Scheduler API.
因此,如果我在新线程上安排任务,并且我想在Java主线程上观察它,我该怎么做？

编辑
下面是一个示例RxSubscription,在system.in注释时,当Observable.interval在一个单独的线程上运行时,Main线程被终止.在AndroID中,我可以说observeOn(AndroIDSchedulers.MainThread),此后的任何 *** 作都将在主线程上运行.我正在寻找类似的Java调度程序,因为AndroIDSchedulers是RxAndroID的一部分.

import java.io.IOException;import java.util.concurrent.TimeUnit;import rx.Observable;public class Main {public static voID main(String[] args) throws InterruptedException, IOException {    Observable<Long> values = Observable.interval(1000, TimeUnit.MILliSECONDS);    values.subscribe(            v -> System.out.println("Received: " + v),            e -> System.out.println("Error: " + e),            () -> System.out.println("Completed")    );    //system.in.read();}}

解决方法:

由于RxJava 1.x没有阻塞调度程序,因此目前无法返回“主”Java线程.

如果你可以升级到RxJava 2.x,我有一个特殊的调度程序,可以“固定”到当前线程：

compile "com.github.akarnokd:rxjava2-extensions:0.15.1"

BlockingScheduler

This type of scheduler runs its execution loop on the “current thread”, more specifically, the thread which invoked its execute() method. The method blocks until the shutdown() is invoked. This type of scheduler allows returning to the “main” thread from other threads.

public static voID main(String[] args) {    BlockingScheduler scheduler = new BlockingScheduler();    scheduler.execute(() -> {        Flowable.range(1, 10)            .subscribeOn(Schedulers.io())            .observeOn(scheduler)            .doAfterTerminate(() -> scheduler.shutdown())            .subscribe(v -> System.out.println(v + " on " + Thread.currentThread()));    });    System.out.println("BlockingScheduler finished");}

总结

以上是内存溢出为你收集整理的RxJava中AndroidSchedulers.mainThread()的替代方法是什么？全部内容，希望文章能够帮你解决RxJava中AndroidSchedulers.mainThread()的替代方法是什么？所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。