Android Kotlin Flow 冷热流详解_开发_开发者

开发者 https://www.devze.com 2024-11-09 10:18 出处：网络作者： wk灬丨

目录冷流（Cold Stream）：热流（Hot Stream）在 android 开发中，Flow 是 Kotlin 协程库的一部分，用于处理异步数据流的一个组件。本质上，Flow 是一个能够异步生产多个值的数据流，与 suspend 函数返回单个值的模式

在 android 开发中，Flow 是 Kotlin 协程库的一部分，用于处理异步数据流的一个组件。本质上，Flow 是一个能够异步生产多个值的数据流，与 suspend 函数返回单个值的模式相对应。Flow 更类似于 RxJava 中的 Observable，但它更轻量级并且完全集成于 Kotlin 协程体系中。

Flow 可以分为两种类型：冷流（Cold Stream）和热流（Hot Stream）

冷流（Cold Stream）：

在代码中直接使用 Flow 默认是一种冷流，只有被调用 collect 函数时数据流逻辑才会开始执行

fun main() {
    runblocking {
        flow<Int> { // 创建一个 Flow 对象
            for (i in 1..5) {
                delay(1000)
                emit(i) // 发出数据
            }
        }.collect { // 接收数据
            println(it)
        }
    }
}

运行结果：

Android Kotlin Flow 冷热流详解

使用 Flow，可以帮助我们更方便地处理异步操作，如网络请求、数据库查询，以及 UI 状态的管理等，通过其非阻塞的特性来提升应用的性能和响应速度。

热流（Hot Stream）

热流在不被调用collect 函数时也可以产生数据，多个订阅者javascript接收的数据是共享的，所以它更像广播的性质。

val shareFlow = MutableSharedFlow<Int>()
fun collectData(name: Int) {
    CoroutineScope(Dispatchers.IO).launch {
        shareFlow.co编程客栈llect { // 作用域阻塞
            println("receive$name: $it")
        }
    }
}
fun main() {
    collectData(1) // 接收者1 接收数据
    collectData(2) // 接收者2 接收数据
    runBlocking {
        for (i in 1..5) {
            delay(1000)
            shareFlow.emit(i) // 发出数据
            println()
        }
    }
}

运行结果：

Android Kotlin Flow 冷热流详解