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

Kotlin协程flow的debounce与管道Channel

Kotlin协程flow的debounce与管道Channel

import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.channels.Channel
import kotlinx.coroutines.delay
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.launch
import kotlinx.coroutines.runBlockingconst val timeOut = 150L
val delayTimes = arrayListOf(50L, 100L, 150L, 200L, 250L)fun main(args: Array<String>) {val channel = Channel<String>()runBlocking {launch(Dispatchers.IO) {repeat(5) {val t = System.currentTimeMillis()println("待发射 $it $t ...")channel.send("$it-$t")val d = delayTimes.random() //从列表中随机选择一个延迟时间。println("$it 休眠 $d")delay(d)}}launch(Dispatchers.IO) {channel.receiveAsFlow().debounce(timeOut).collect {println("debounce $it")}}println("runBlocking")}//channel.receiveAsFlow()将永恒处于接收状态,走不到channel.close()这里//channel.close()
}

待发射 0 1693126278615 ...
runBlocking
0 休眠 100
待发射 1 1693126278746 ...
1 休眠 50
待发射 2 1693126278810 ...
2 休眠 200
debounce 2-1693126278810
待发射 3 1693126279011 ...
3 休眠 50
待发射 4 1693126279075 ...
4 休眠 50
debounce 4-1693126279075

        <!-- https://mvnrepository.com/artifact/org.jetbrains.kotlinx/kotlinx-coroutines-core --><dependency><groupId>org.jetbrains.kotlinx</groupId><artifactId>kotlinx-coroutines-core</artifactId><version>1.7.3</version><type>pom</type></dependency>

https://zhangphil.blog.csdn.net/article/details/131103698icon-default.png?t=N7T8https://zhangphil.blog.csdn.net/article/details/131103698

kotlin协程管道Channel_zhangphil的博客-CSDN博客runBlocking 内部启动的3个协程做耗时操作,从输出可以看到3个协程交叉并发执行,runBlocking 会等到3个协程执行结束后才退出,输出结果有明确先后顺序。runBlocking 会等待相同作用域的协程完成才退出runBlocking 本身阻塞线程,但内部运行的协程又非阻塞。kotlin的runBlocking 当内部相同作用域的所有协程都运行结束后,在 runBlocking 之后的代码才能执行, runBlocking 会阻塞所在线程。kotlin协程管道Channel。https://blog.csdn.net/zhangphil/article/details/131096899Kotlin协程flow发送时间间隔debounce_zhangphil的博客-CSDN博客debounce蕴含了一定的缓冲思想,即,不立刻触发事件,而是先把要发射的数据进入队列,稍等一定时间(时间)延迟触发,而触发的重要条件取决于前一条数据和后一条数据的时间间隔,注意,前一条和后一条尚未被发射出去,只是待命中。发射完ABC,Kotlin审视待发射的ABCD,按理说ABCD与ABC间隔200,满足发射timeOut值,但是ABCD与ABCDE间隔100,所以跳过ABCD,直接发射ABCDE。四、map,重组改写数据。A和AB都待发射,A和AB间隔100,所以跳过A,直接发射AB。https://blog.csdn.net/zhangphil/article/details/132515686kotlin协程接收管道ReceiveChannel生产者produce_kotlin produce_zhangphil的博客-CSDN博客runBlocking 内部启动的3个协程做耗时操作,从输出可以看到3个协程交叉并发执行,runBlocking 会等到3个协程执行结束后才退出,输出结果有明确先后顺序。runBlocking 会等待相同作用域的协程完成才退出runBlocking 本身阻塞线程,但内部运行的协程又非阻塞。kotlin的runBlocking 当内部相同作用域的所有协程都运行结束后,在 runBlocking 之后的代码才能执行, runBlocking 会阻塞所在线程。kotlin协程管道Channel。_kotlin producehttps://blog.csdn.net/zhangphil/article/details/131103072

http://www.lryc.cn/news/148291.html

相关文章:

  • 在JavaScript中,你可以使用多种方法来查找包含特定元素的数组或对象
  • 实力认证!OceanBase获“鼎信杯”优秀技术支撑奖
  • 分布式锁实现一. 利用Mysql数据库update锁
  • 第一百三十一回 如何使用MethodChannel
  • 贝锐蒲公英异地组网方案,如何阻断网络安全威胁?
  • CTFhub-文件上传-无验证
  • Java“牵手”京东商品详情数据,京东API接口申请指南
  • 瓜分双十一10亿红包设计:在线分享教程?
  • day 43 | ● 123.买卖股票的最佳时机III ● 188.买卖股票的最佳时机IV
  • 客路旅行(KLOOK)面试(部分)(未完全解析)
  • 时序预测 | MATLAB实现基于QPSO-BiGRU、PSO-BiGRU、BiGRU时间序列预测
  • el-select码值枚举
  • 【多面体:知识蒸馏:Pansharpening】
  • 【python爬虫】4.爬虫实操(菜品爬取)
  • 深圳发墨西哥专线要多久才能清关?
  • Java-泛型
  • 【python爬虫】8.温故而知新
  • vue3组合式api 父子组件数据同步v-model语法糖的用法
  • 环境异常总结
  • [论文笔记]DSSM
  • Skip Connection——提高深度神经网络性能的利器
  • EXCEL中点击单元格,所在行和列都改变颜色
  • HAProxy(一)
  • LeetCode--HOT100题(46)
  • 深度探索JavaScript中的原型链机制
  • 一种基于WinDump自动抓包实现方法
  • taro 支付宝/微信小程序/h5 上传 - base64的那些事儿
  • java之SpringBoot基础、前后端项目、MyBatisPlus、MySQL、vue、elementUi
  • Vue-Router 一篇搞定 Vue3
  • 深度解读智能媒体服务的重组和进化