为什么我的线程数增加并出现rxjava重试错误？

Question

[在函数方法中，我抛出nullPointerException并打印出线程数（sout（Thread.activeCount）。似乎每次我重试错误时，threadCount都会增加1。为什么会发生这种情况？我应该假定它只会收集垃圾吗？

public void start(int time) {
    Observable.interval(time, TimeUnit.SECONDS)
            .doOnNext(t -> function())
            .doOnError(System.out::println)
            .retry()
            .subscribe();

}

Answer 1

也许Obse​​rvable.interval（）每次重试时都会从其计算调度程序线程池中获取新线程。可能是因为当时仍在使用以前的线程，所以这样做了吗？恕我直言，它不应无限期地上升，因为它将表明一些错误。