Android面试题之kotlin热流和channel

本文首发于公众号“AntDream”,欢迎微信搜索“AntDream”或扫描文章底部二维码关注,和我一起每天进步一点

于冷流不同,在垃圾回收之前,flow里的值都是存在内存之中,并且处于活跃状态

StateFlow

StateFlow是一个状态容器式可观察数据流,可以向其收集器发出当前状态更新和新状态更新。还可通过其value属性读取当前的状态值

  • 和livedata比较像,有新数据可以通知collect的一方
  • 同时又具有flow的所有特点,比如可以挂起,切换线程
SharedFlow

SharedFlow会向其中收集值得所有使用方发出数据

  • 也就是一对多的关系,可以有多个collector
  • 同时又具有flow的所有特点,比如可以挂起,切换线程
  • 和上面的StateFlow不同的是,这个不能主动通知collect方,需要不断emit元素,也就是利用了flow的功能
channel
定义概念
  • channel实际上是一个并发安全的队列,它可以用来连接协程,实现不同协程的通信
  • channel实际上就是一个队列,队列中一定存在缓冲区,那么这个缓冲区一旦满了,并且也一直没有人调用receive并取走函数,send就需要挂起。
  • 默认缓冲区大小是0
val channel = Channel<Int>()@Test
fun `test channel` ()= runBlocking<Unit>{val producer = GlobalScope.launch { var i = 0;while (true){delay(1000)channel.send(++i)println("send $i")}}val consumer = GlobalScope.launch { while (true){val element = channel.receive()println("receive $element")}}joinAll(producer, consumer)
}
  • 在读取channel时可以直接获取一个channel的iterator迭代器
val iterator = channel.iterator()
while (iterator.hasNext()){val element = iterator.next()
}//也可以这样
for (element in channel){}
produce与actor
  • 构造生产者和消费者的便捷方法
  • 可以通过produce方法启动一个生产者协程,并返回一个ReceiveChannel,其他协程就可以用这个Channel来接受数据。反过来,我们可以用actor启动一个消费者协程。
val receiveChannel: ReceiveChannel<Int> = GlobalScope.produce {repeat(100){delay(1000)send(it)}
}
val consumer = GlobalScope.launch {for (i in receiveChannel){println("receive $i")}
}val sendChannel:SendChannel<Int> = GlobalScope.actor {while (true){val element = receive()println(element)}
}
val producer = GlobalScope.launch {for (i in 1..3){sendChannel.send(i)}
}
channel的关闭
  • produce与actor返回的channel都会随着对应的协程执行完毕而关闭
  • 对于一个channel,如果我们调用了它的close方法,它会立即停止接受新元素,也就是说这时它的isClosedForSend会立即返回true。而由于channel缓冲区的存在,这时候可能还有元素没有被处理完,因此要等所有的元素都被读取之后isClosedForReceive才会返回true
  • channel的生命周期最好由主导方来维护,建议由主导的一方实现关闭
BroadcastChannel

发送端和接收端在Channel中存在一对多的情形,从数据处理本身来说,虽然有多个接收端,但是同一个元素只会被一个接收端读到。广播则不然,多个接收端不存在互斥行为


欢迎关注我的公众号查看更多精彩文章!
AntDream

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/835974.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

【Python】items()方法的介绍和使用方式

相关链接&#xff1a;【Python】顺序字典&#xff08;OrderedDict&#xff09;的定义和使用方式 相关链接&#xff1a;【Python】普通字典的定义和使用方式 相关链接&#xff1a;【Python】get()方法的介绍和使用方式 在 Python 中&#xff0c;字典&#xff08;dict&#xff0…

DSA理解理解蓝桥杯例题signature

一、历史 1991年8月&#xff0c;NIST&#xff08;Nation Institute of Standards and Technology&#xff0c;美国国家标准技术研究所&#xff09;提出了数字签名算法&#xff08;DSA&#xff09;用于他们的数字签名标准&#xff08;DSS&#xff09;中。 DSA是算法&#xff0c…

什么是渐进式框架

渐进式框架是一种设计理念&#xff0c;它允许开发者根据项目需求逐步采用框架的功能。这意味着你可以从一个非常轻量、简洁的开始&#xff0c;根据实际需要不断引入更多的组件和功能。这种方式的好处在于它使得项目的起点低、上手快&#xff0c;同时随着项目的增长&#xff0c;…

双向带头循环链表(图解)

文章目录 头节点(哨兵位)双向循环结构头插尾插头删尾删在指定位置之前插入数据删除指定位置之前的数据销毁链表 全部代码结语 单链表地址 头节点(哨兵位) 什么是头节点呢?头节点也叫哨兵节点,他在链表中进行不了任何操作,只是用来放哨用的,在单链表中我们当我们尾插的时候我们…

使用Flask构建POST请求的Web应用

文章目录 准备工作创建路由处理POST请求创建表单页面运行应用结论 在Web开发中&#xff0c;处理POST请求是一项常见任务&#xff0c;特别是在构建表单提交、用户注册和数据提交等功能时。Flask是一个简单而强大的Python Web框架&#xff0c;它提供了方便的工具来处理HTTP请求&a…

文章解读与仿真程序复现思路——电力自动化设备EI\CSCD\北大核心《考虑微电网联盟协调运行的用户侧共享储能多计费方式博弈定价方法》

本专栏栏目提供文章与程序复现思路&#xff0c;具体已有的论文与论文源程序可翻阅本博主免费的专栏栏目《论文与完整程序》 论文与完整源程序_电网论文源程序的博客-CSDN博客https://blog.csdn.net/liang674027206/category_12531414.html 电网论文源程序-CSDN博客电网论文源…

C# WPF控件ViewBox详解

目录 一、引言 二、Viewbox定义与基础概念 三、常用属性 四、事件处理 五、实际应用 六、高级技巧与最佳实践 七、总结 一、引言 在C#的WPF&#xff08;Windows Presentation Foundation&#xff09;框架中&#xff0c;Viewbox是一个非常重要的布局控件。它允许开发者在不…

打开远程连接的命令是什么?

远程连接是一种能够在不同设备之间建立连接并共享信息的技术。在许多情况下&#xff0c;我们需要通过远程连接来访问其他设备或处理一些远程任务。本文将介绍一些常用的打开远程连接的命令。 使用SSH连接远程设备 SSH&#xff08;Secure Shell&#xff09;是一种安全的网络协议…

React 第二十四章 shouldComponentUpdate

React 中的 shouldComponentUpdate 是一个生命周期方法&#xff0c;用于控制组件是否需要重新渲染。 文档地址&#xff1a;https://zh-hans.reactjs.org/docs/react-component.html#shouldcomponentupdate shouldComponentUpdate 接收两个参数&#xff1a;nextProps 和 nextS…

Matlab/simulink永磁直驱风机的建模仿真

Matlab/simulink直驱永磁同步风机的建模仿真&#xff0c;跟随风速波动效果好&#xff0c;可以作为后期科研的基础模型

【数据库】数据库事务原理

事务特性 https://blog.csdn.net/zxcyxg123/article/details/132020499 MVCC MVCC&#xff08;Multi-Version Concurrency Control&#xff09;&#xff0c;即多版本并发控制&#xff0c;是一种并发控制的方法&#xff0c;主要用于数据库管理系统中&#xff0c;以实现对数据库…

达索电磁仿真软件CST查看方式和消除2D/3D图的反射效果【官方教程】

消除2D/3D图的反射效果 查看和分析2D/3D结果时消除不必要的反射效果 View > Options > View Options > Specials 正面看CST软件的3D场分布图时&#xff0c;如下图所示&#xff0c;因为反射效果导致无法看清楚。本章节介绍一下相应的解决方法。 因为View Options的S…

GitLab CI/CD的原理及应用详解(四)

本系列文章简介&#xff1a; 在当今快速变化的软件开发环境中&#xff0c;持续集成&#xff08;Continuous Integration, CI&#xff09;和持续交付&#xff08;Continuous Delivery, CD&#xff09;已经成为提高软件开发效率、确保代码质量以及快速响应市场需求的重要手段。Gi…

RabbitMQ的用途

RabbitMQ主要有四个用途&#xff0c;分别是应用解耦、异步提速、削峰填谷、消息分发。详情讲解如下&#xff1a; RabbitMQ介绍、解耦、提速、削峰、分发 详解、RabbitMQ安装 可视化界面讲解 1.应用解耦&#xff1a;提高系统容错性和可维护性 2.异步提速&#xff1a;提升用户体验…

【18-Ⅰ】Head First Java 学习笔记

HeadFirst Java 本人有C语言基础&#xff0c;通过阅读Java廖雪峰网站&#xff0c;简单速成了java&#xff0c;但对其中一些入门概念有所疏漏&#xff0c;阅读本书以弥补。 第一章 Java入门 第二章 面向对象 第三章 变量 第四章 方法操作实例变量 第五章 程序实战 第六章 Java…

PyCharm粘贴失灵?一文教你快速恢复!(如何解决Pycharm无法粘贴的问题)

文章目录 💢 问题 💢🏡 演示环境 🏡💯 解决方案 💯⚓️ 相关链接 ⚓️💢 问题 💢 "为什么你的代码编辑器突然变得不听话了?"最近在使用pycharm的时候遇到了一个问题,就是在pycharm中无法使用粘贴功能,后面经过一番折腾得到了解决,现在将我的解决…

自然资源-土地征收程序梳理

自然资源-土地征收程序梳理 土地征收是指国家为了公共利益需要&#xff0c;依照法律规定的程序和权限将农民集体所有的土地转化为国有土地&#xff0c;并依法给予被征地的农村集体经济组织和被征地农民合理补偿和妥善安置的法律行为。 1.预公告 三次公告之第一次。 《土地管…

mac中launchctl使用教程

launchctl是macOS系统中用于管理和控制系统服务和守护进程的命令行工具。下面是一些常见的launchctl命令和用法示例&#xff1a; 启动一个服务&#xff1a; launchctl start <service_name>停止一个服务&#xff1a; launchctl stop <service_name>加载一个plis…

scanf留下的那一片云彩

【题目描述】 给出一个由O和X组成的串&#xff08;长度为1&#xff5e;80&#xff09;&#xff0c;统计得分。每个O的得分为目前连续出现的O的个数&#xff0c;X的得分为0。例如&#xff0c;OOXXOXXOOO的得分为1200100123。 输入第一行表示有n个字符串&#xff0c;后续是n行字…

自然资源-城镇开发边界内详细规划编制技术指南解读

自然资源-城镇开发边界内详细规划编制技术指南解读