在这种情况下，Observable 会因为被垃圾收集而停止发射吗？

Question

我想知道在这种情况下 observable 是否有资格被垃圾收集：

fun getObservable() = Observable.interval(500, TimeUnit.Milliseconds)

fun main(args: Array<String>) {
    getObservable().subscribe { println(it) }

    //Just to be able to observe the output.
    Thread.sleep(20*1000)
}

它不会停止发射。但我不能用它来确定它不会在一段时间后被 GC，因为它可能只是在这么短的时间内没有触发 GC。

我的猜测是它应该是 GC'd。我们没有对从getObservable() 函数返回的Observable 的引用，因为我们不能再访问它了。再次调用该函数将给出不同的新Observable。由于我们无法访问Observable 本身，因此其余对象也无法访问。所以，我认为所有这些都可以在任何随机时间被垃圾收集。

我在 Android 应用中的一些代码使用了一些类似的代码。这是一个Observable，我希望它和Application一样长。因为，GC 会收集任何垃圾，我不希望我的Observable 在我的应用程序中间被 GC。所以，请记住，我不是在寻找告诉我它是否会被 GC 的答案。我关心的是能不能被GC。

感谢您抽出时间来帮助我。

编辑：为了使上下文更清晰，这是我在应用程序中使用相关代码的基本思想。

Repository.kt：

interface Repository {

    //Other code.

    fun getUserPrefs(): Flowable<UserPreference>
}

MyViewModel.kt：

class MyViewModel(private val repository: Repository): ViewModel() {

    init {
        repository.getUserPrefs()
            .subscribe { //Code with UI state side effects }
    }
}

在我的应用程序中，Repository 的实现将是一个单例。对于那些不熟悉 Android 的人，只知道 ViewModel 可以持续很长时间。它的工作基本上是负责管理UI状态。

Answer 1

所以在sleep main 退出并且发射停止之后。如果你用Thread.sleep(1000) 试试，你会发现它只输出

0
1

原因是你的程序终止了。

你想要的可能是blockingSubscribe:

getObservable().blockingSubscribe { println(it) }

只有在 Observable 完成后才会返回。

请注意，您可以订阅 3 种类型的事件：onNext、onError 和 onComplete：

getObservable().blockingSubscribe({
    println(it)
}, {
    throw it
}, {
    println("finished")
})

订阅所有 3 项不会改变订阅者超出范围的事实，因此您仍需要使用 blockingSubscribe。如果你想卸载线程之间的工作，你可以使用subscribeOn 和observeOn：

getObservable()
        .subscribeOn(Schedulers.computation())
        .observeOn(Schedulers.single())
        .blockingSubscribe {
            println(it)
        }

您可以阅读有关这些in this question 的更多信息。

关于垃圾回收：

Java 垃圾收集器足够智能，可以回收相互引用但未被所谓的“根引用”引用的资源：

 (Root reference)

 (obj0) --> (obj1)
  \          /
   \        /
    \      /
    (obj2)

^^^--- obj0, 1 and 2 are eligible for garbage collection

那么为什么你的Observable 会在与其他对象分离的情况下继续运行？答案是 Java 中有多种类型的“根”引用：

• 局部变量
• 活动 Java 线程
• 静态变量
• JNI 参考资料

在您的情况下，当您在 Observable 上调用 subscribe 时，它会将工作卸载到 RxJava-s 线程，这些线程本身就是“根”引用，因此即使您没有任何这些对象的引用，它们也会仍然无限期地运行广告或直到Threads 终止。