当前位置: 首页 > article >正文

Kotlin的数据流

LiveData 则是一种可观察的数据存储器类,与常规的可观察类不同,LiveData 具有生命周期感知能力,它遵循其他应用组件(如 Activity、Fragment 或 Service)的生命周期。这种感知能力可确保LiveData当数据源发生变化的时候,通知它的观察者更新UI界面。同时它只会通知处于Active状态的观察者更新界面,如果某个观察者的状态处于Paused或Destroyed时那么它将不会收到通知,所以不用担心内存泄漏问题。

特点如下:

  • 观察者的回调永远发生在主线程
  • 仅持有单个且最新的数据
  • 自动取消订阅
  • 提供「可读可写」和「仅可读」两个版本收缩权限
  • 配合 DataBinding 实现「双向绑定」

一些缺陷:

  • value 可以是 nullable 的
  • 在 fragment 订阅时需要传入正确的 lifecycleOwner
  • 当 LiveData 持有的数据是「事件」时,可能会遇到「粘性事件」
  • LiveData 是不防抖的
  • LiveData 的 transformation 需要工作在主线程

随着 RxJava 的流行,响应式编程模型逐步深入人心。Flow 就是 Kotlin 协程与响应式编程模型结合的产物。

Flow是Google官方提供的一套基于kotlin协程的响应式编程模型,它与RxJava的使用类似,但相比之下Flow使用起来更简单,另外Flow作用在协程内,可以与协程的生命周期绑定,当协程取消时,Flow也会被取消,避免了内存泄漏风险。

协程是轻量级的线程,本质上协程、线程都是服务于并发场景下,其中协程是协作式任务,线程是抢占式任务。默认协程用来处理实时性不高的数据,请求到结果后整个协程就结束了。

冷流和热流

Kotlin的数据流主要由三个成员组成,分别是生产者、消费者和中介。 生产者:生成添加到数据流中的数据,可以配合得协程使用,使用异步方式生成数据。 中介(可选):可以修改发送到数据流的值,或修正数据流本身。 消费者:使用方则使用数据流中的值。

其中,中介可以对数据流中的数据进行更改,甚至可以更改数据流本身。

在Kotlin中,Flow 是一种冷流,不过有一种特殊的Flow( StateFlow/SharedFlow) 是热流。什么是冷流,他和热流又有什么关系呢?

冷流:只有订阅者订阅时,才开始执行发射数据流的代码。并且冷流和订阅者只能是一对一的关系,当有多个不同的订阅者时,消息是重新完整发送的。也就是说对冷流而言,有多个订阅者的时候,他们各自的事件是独立的。 热流:无论有没有订阅者订阅,事件始终都会发生。当 热流有多个订阅者时,热流与订阅者们的关系是一对多的关系,可以与多个订阅者共享信息。

Flow操作符

Flow和RxJava一样,用各种操作符撑起了异步数据流框架的半边天。Flow默认为冷流,即下游有消费时,才执行生产操作。

所以,操作符也被分为两类——中间操作符和末端操作符,中间操作符不会产生消费行为,返回依然为Flow,而末端操作符,会产生消费行为,即触发流的生产。

参考资料:

破解 Kotlin 协程(11):Flow 篇 | Benny Huo


http://www.kler.cn/a/4490.html

相关文章:

  • 微服务之松耦合
  • 灵活妙想学数学
  • 初始Java4
  • 单片机的原理及其应用:从入门到进阶的全方位指南
  • C++并发编程之std::partial_sum的并行版本
  • 39.【4】CTFHUB web sql 布尔注入
  • java反编译工具
  • Springboot整合rabbitmq并实现消息可靠性和持久性
  • css3 position定位—— sticky 定位
  • Maven - Explain in Detail
  • spark笔记(自用)
  • 进程与子进程
  • java源码阅读 - HashTable
  • 提升代码可读性,减少 if-else 的几个小技巧
  • 合泰HT32单片机使用PDMA和ADC采集多路模拟值并显示在OLED屏上
  • Vue+springboot笔记本电脑商城销售系统
  • 校招失败后,在外包公司熬了 2 年终于进了字节跳动,竭尽全力....
  • python Django运用——(1.创立项目)
  • 进程与线程的关系
  • 【协议】03、深度解剖之HTTP协议
  • leetcode 有序数组的平方(977)
  • (四)Tomcat源码阅读:Service组件分析
  • 垃圾回收机制——把我回收了吧
  • 我的黑苹果安装经验
  • 深入浅出Java线程池Worker类
  • Java Web的三种获取参数的方法