不要把多个Flow放进一个lifecycleScope.launch里collect{}！这是Kotlin Flow使用的大忌

2022-12-29 01:42:49

Flow：协程编程的利器

Flow使用注意事项

Flow是一个用于协程编程的强大库，它可以帮助开发者轻松实现异步编程和数据流上下游通信。然而，在使用Flow时，有几个需要注意的关键事项：

1. 避免在一个协程中收集多个Flow

这是Flow使用中常见的一个错误！因为collect{}方法本质上是一个挂起函数，它会一直等待数据流中的数据，直到数据流关闭或取消。如果有多个Flow同时放在一个协程中使用collect{}方法收集，那么它们就会相互等待，形成一个死循环，导致下一行代码无法执行。

如何避免这个问题？

如果你想同时处理多个Flow，可以使用Flow.combine()、Flow.zip()等操作符将它们组合成一个新的Flow，然后再去collect{}。这样可以避免死循环的问题。

// ❌ 错误示例
lifecycleScope.launch {
    flow1.collect {}
    flow2.collect {}
}

// ✅ 正确示例
val combinedFlow = flow1.combine(flow2) { a, b -> a + b }
lifecycleScope.launch {
    combinedFlow.collect {}
}

2. Flow只能在协程中使用

Flow是一个协程库，只能在协程中使用。如果你想在主线程中使用Flow，可以使用Flow.asLiveData()将Flow转换为LiveData，然后再去observe()。

// ❌ 错误示例
runOnUiThread {
    flow.collect {}
}

// ✅ 正确示例
lifecycleScope.launch {
    flow.asLiveData().observe(this) { data ->
        // 在这里处理数据
    }
}

3. Flow需要手动取消

Flow是惰性执行的，只有在有人订阅它时才会开始执行。如果你不再需要某个Flow，需要手动取消它，以避免内存泄漏。可以使用Flow.cancel()方法取消Flow。