Kotlin中 StateFlow 或 SharedFlow 的区别解析_ar

stateflow 和 sharedflow 是 kotlin 协程（coroutines） 提供的两种 响应式数据流（reactive streams），用于在应用程序中处理异步数据流，类似于 rxjava 的 observable 或 flowable，但更轻量且与 kotlin 协程深度集成。

1. stateflow（状态流）

stateflow 是一种 热流（hot flow），它会存储当前的状态值，并在状态变化时通知所有订阅者。

特点

必须有初始值（不能为空）。
只保留最新的值（新订阅者会立即收到当前值）。
是 sharedflow 的特殊情况（相当于 replay=1 的 sharedflow）。
适用于 ui 状态管理（如 viewmodel 暴露 ui 状态）。

示例

// 定义 stateflow（通常在 viewmodel 中）
private val _counterstate = mutablestateflow(0) // 初始值 0
val counterstate: stateflow<int> = _counterstate.asstateflow()
// 更新值
fun increment() {
    _counterstate.value++ // 自动通知所有订阅者
}
// 在 activity/fragment 中监听
lifecyclescope.launch {
    viewmodel.counterstate.collect { value ->
        textview.text = "count: $value"
    }
}

2. sharedflow（共享流）

sharedflow 也是一种热流，但它不存储状态，而是用于 广播事件（如一次性事件、通知等）。

特点

没有初始值（可以发送任意数量的数据）。
可以配置缓存大小（replay 控制新订阅者能收到多少历史数据）。
适用于事件总线、通知等场景（如 toast 消息、导航事件）。

示例

// 定义 sharedflow（通常在 viewmodel 中）
private val _toastevent = mutablesharedflow<string>() // 无初始值
val toastevent: sharedflow<string> = _toastevent.assharedflow()
// 发送事件
fun showtoast(message: string) {
    viewmodelscope.launch {
        _toastevent.emit(message) // 发送事件
    }
}
// 在 activity/fragment 中监听
lifecyclescope.launch {
    viewmodel.toastevent.collect { message ->
        toast.maketext(this, message, toast.length_short).show()
    }
}

stateflow vs sharedflow

特性	`stateflow`	`sharedflow`
初始值	✅ 必须有	❌ 不需要
缓存历史数据	仅最新值	可配置 (`replay`)
适用场景	ui 状态管理（如 `livedata` 替代）	事件总线、通知
是否热流	✅ 是	✅ 是
线程安全	✅ 是（协程作用域内）	✅ 是

因此，以下面这段代码举例：

/**
     * 应用中心数据变化，更新应用中心小组件的显示
     */
    private fun widgetselectorviewmodel.observerapplist() = coroutinescope.launch {
        appwidgets.oneach { list ->
            log.d(tag, "observerapplist setdatalist")
            gridadapterapp.setdatalist(list)
            appitembinding?.groupnodata?.isvisible = list.isempty()
        }.launchin(coroutinescope)
    }

功能总结：
这段代码的主要作用是监听应用小组件列表(appwidgets)的变化，每当列表更新时：

将新列表设置给网格适配器(gridadapterapp)以更新ui

根据列表是否为空来显示或隐藏"无数据"的提示

所有这些操作都在协程中异步执行

这是一种典型的响应式编程模式，通过观察数据流来自动更新ui，避免了手动刷新数据的需要。

首先是函数定义：

private fun widgetselectorviewmodel.observerapplist() = coroutinescope.launch {

这是一个 widgetselectorviewmodel 的扩展函数
函数是私有的(private)
返回一个协程启动器(launch)
函数名为 observerapplist()，表示它用于观察应用列表

其次是函数体：

appwidgets.oneach { list ->
    gridadapterapp.setdatalist(list)
    appitembinding?.groupnodata?.isvisible = list.isempty()
}.launchin(coroutinescope)