使用调度程序时，System.out.println 在 RxJava 中不打印任何内容

Question

我正在摆弄 RxJava 和调度程序。我使用调度程序实现了一个非常简单的流：

Observable.just(1, 2, 3)
      .doOnNext(v -> Thread.currentThread().getName())
      .subscribeOn(Schedulers.newThread())
      .subscribe(v -> System.out.println(v));

上面的示例在控制台中打印 nothing。

我注意到，当我在末尾使用 Thread.sleep() 阻塞主线程时，System.out.println 打印正确的值 - 1 2 3:

Observable.just(1, 2, 3)
        .doOnNext(v -> Thread.currentThread().getName())
        .subscribeOn(Schedulers.newThread())
        .subscribe(v -> System.out.println(v));

        try {
            Thread.sleep(10);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

谁能帮我理解这种行为？

Answer 1

RXJava 使用 daemon 个线程。所以你的应用程序在你的 Observable 开始发射之前就完成了。这很容易检查，只需传递 Scheduler 哪个 returns 非 daemon 线程，您将看到您的输出值：

Scheduler scheduler = Schedulers.from(Executors.newCachedThreadPool(new ThreadFactory() {
    @Override public Thread newThread(Runnable r) {
        Thread result = new Thread(r);
        //result.setDaemon(true);
        return result;
    }
}));

Observable.just(1, 2, 3)
        .subscribeOn(scheduler)
        .subscribe(v -> print(v));

取消注释行 result.setDaemon(true); 并且不会打印值。

使用调度程序时，System.out.println 在 RxJava 中不打印任何内容

When using Schedulers, System.out.println prints nothing in RxJava

java

multithreading

scheduler

rx-java