AndroidScheduler的替代方案是什么。RxJava中的mainThread（）？

Question

RxJava中是否有与RxAndroid中的AndroidSchedulers.mainThread（）同义的Scheduler api。因此，如果我在一个新线程上安排一个任务，并且我想在Java主线程上观察它，我将如何做到这一点？

下面的edit是一个RxSubscription示例，带有system。在注释中，主线程被终止，而可观察线程被终止。interval在单独的线程上运行。在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();
}
}

Answer 1

是的，RxJava有调度程序。要向任何线程发送消息，你需要有一个某种消息循环来等待来自其他线程的消息。在Android中，这是你的Looper。在Java，你需要自己做这件事。然后你的调度程序会向该线程发送一条消息，并在该消息响应中完成工作。这种机制取决于你如何实现你的消息队列，但应该是相当微不足道的。

Answer 2

目前无法返回“主”Java线程，因为RxJava 1没有阻塞调度程序。x。

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

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

阻塞调度程序

这种类型的调度程序在“当前线程”上运行其执行循环，更具体地说，是调用其执行（）方法的线程。该方法会阻塞，直到调用关闭（）。这种类型的调度程序允许从其他线程返回“主”线程。

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");
}