java - 使用 Schedulers 时，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));

上面的示例在控制台中不打印任何内容。

我注意到，当我最后使用 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 即可，您将看到输出值:

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); 并且不会打印值。