线程切换哪家强?RxJava与Flow的操作符对比
作者:fundroid
链接:https://juejin.cn/post/6943037393893064734#heading-13
Flow
作为Coroutine版的RxJava,同RxJava一样可以方便地进行线程切换。本文针对两者在多线程场景中的使用区别进行一个简单对比。
1、RxJava
我们先来回顾一下RxJava中的线程切换
如上,RxJava使用subscriberOn与observeOn进行线程切换
1.1 subscribeOn
subscribeOn用来决定在哪个线程进行订阅,对于Cold流来说即决定了数据的发射线程。使用中有两点注意:
当调用链上只有一个subscribeOn时,可以出现在任意位置
上面两种写法效果是一样的:都是在io线程订阅后发射数据
当调用链上有多个subscribeOn时,只有第一个生效:
上面第二个subscribeOn没有意义
1.2 observeOn
observeOn用来决定在哪个线程上响应:
observeOn决定调用链上下游操作符执行的线程
上面绿线部分的代码将会运行在主线程
与subscribeOn不同,调用链上允许存在多个observeOn且每个都有效
上面蓝色绿色部分因为observeOn的存在分别切换到了不同线程执行
1.3 just
RxJava的初学者经常会犯的一个错误是在Observable.just(...)里做耗时任务。just并不是接受lambda,所以是立即执行的,不受subscribeOn的影响
如上,loadDataSync()不会在io执行,
想要在io执行,需要使用Observable.deffer{}
1.4 flatMap
结合上面介绍的RxJava的线程切换,看下面这段代码
如果我们希望loadData(id)并发执行,那么上面的写法是错误的。
subscribe(io())意味着其上游的数据在单一线程中串行发射。因此虽然flatMap{}返回多个Observable, 都是都在单一线程中订阅,多个loadData始终运行在同一线程。
代码经过一下修改后,可以达到并发执行的效果:
当订阅flatMap返回的Observable时,通过subscribeOn分别指定订阅线程。
其他类似flatMap这种涉及多个Observable订阅的操作符(例如merge、zip等),需要留意各自的subscribeOn的线程,以防不符合预期的行为出现。
2、Flow
接下来看一下Flow的线程切换 。
Flow是基于CoroutineContext进行线程切换,所以这部分内容需要你对Croutine事先有基本的了解。
flowOn类似于RxJava的subscribeOn,Flow中没有对应observeOn的操作符,因为collect是一个suspend函数,必须在CoroutineScope中执行,所以响应线程是由CoroutineContext决定的。例如你在main中执行collect,那么响应线程就是Dispatcher.Main
2.1 flowOn
说flowOn类似于subscribeOn,因为它们都可以用来决定上游线程
上面代码中,flowOn前面代码将会在IO执行。
与subscribeOn不同的是,flowOn允许出现多次,每个都会影响其前面的操作
上面代码,根据颜色可以看出来flowOn影响的范围
2.2 launchIn
collect是suspend函数,所以后续代码因为协程挂起不会继续执行
所以上面代码可能会不符合预期,因为第一个collect不走完第二个走不到。
正确的写法是为每个collect单独起一个协程
或者使用launchIn,写法更加优雅
launchIn不会挂起协程,所以与RxJava的subscribe更加接近。
通过名字可以感觉出来launchIn只不过是之前例子中launch的一个链式调用的语法糖。
2.3 flowOf
flowOf类似于Observable.just(),需要注意flowOf内的内容是立即执行的,不受flowOn影响
希望calculate()运行在IO,可以使用flow{ }
2.4 flatMapMerge
flatMapMerge类似RxJava的flatMap
如上,2个item各自flatMap成2个item,即一共发射了4条数据,日志输出如下:
inner: pool-2-thread-2 @coroutine#4
inner: pool-2-thread-3 @coroutine#5
inner: pool-2-thread-3 @coroutine#5
inner: pool-2-thread-2 @coroutine#4
collect: pool-1-thread-2 @coroutine#2
collect: pool-1-thread-2 @coroutine#2
collect: pool-1-thread-2 @coroutine#2
collect: pool-1-thread-2 @coroutine#2
通过日志我们发现flowOn虽然写在flatMapMerge外面,inner的日志却可以打印在多个线程上(都来自pool2线程池),这与flatMap是不同的,同样场景下flatMap只能运行在线程池的固定线程上。
如果将flowOn写在flatMapMerge内部
结果如下:
inner: pool-2-thread-2 @coroutine#6
inner: pool-2-thread-1 @coroutine#7
inner: pool-2-thread-2 @coroutine#6
inner: pool-2-thread-1 @coroutine#7
collect: pool-1-thread-3 @coroutine#2
collect: pool-1-thread-3 @coroutine#2
collect: pool-1-thread-3 @coroutine#2
collect: pool-1-thread-3 @coroutine#2
inner仍然打印在多个线程,flowOn无论写在flatMapMerge内部还是外部,对flatMapMerge内的处理没有区别。
但是flatMapMerge之外还是有区别的,看下面两段代码
通过颜色可以知道flowOn影响的范围,向上追溯到flowOf为止
3、Summary
RxJava的Observable与Coroutine的Flow都支持线程切换,相关API的对比如下:
线程池调度 | 线程操作符 | 数据源同步创建 | 异步创建 | 并发执行 | |
---|---|---|---|---|---|
RxJava | Schedulers (io(), computation(), mainThread()) | subscribeOn, observeOn | just | deffer{} | flatMap(inner subscribeOn) |
Flow | Dispatchers (IO, Default, Main) | flowOn | flowOf | flow{} | flatMapMerge(inner or outer flowOn) |
最后通过一个例子看一下如何将代码从RxJava迁移到Flow
3.1 RxJava
RxJava代码如下:
使用到的Schedulers定义如下:
代码执行结果:
1: pool-1-thread-1
1: pool-1-thread-1
1: pool-1-thread-1
2: pool-3-thread-1
2: pool-3-thread-1
2: pool-3-thread-1
inner 1: pool-4-thread-1
inner 1: pool-4-thread-2
inner 1: pool-4-thread-1
inner 1: pool-4-thread-1
inner 1: pool-4-thread-2
inner 1: pool-4-thread-2
inner 1: pool-4-thread-3
inner 2: pool-5-thread-1
inner 2: pool-5-thread-2
3: pool-5-thread-1
inner 2: pool-5-thread-2
inner 1: pool-4-thread-3
inner 2: pool-5-thread-2
inner 2: pool-5-thread-3
3: pool-5-thread-1
3: pool-5-thread-1
3: pool-5-thread-1
end: pool-6-thread-1
end: pool-6-thread-1
inner 1: pool-4-thread-3
end: pool-6-thread-1
3: pool-5-thread-1
inner 2: pool-5-thread-1
3: pool-5-thread-1
inner 2: pool-5-thread-3
inner 2: pool-5-thread-1
end: pool-6-thread-1
3: pool-5-thread-3
3: pool-5-thread-3
end: pool-6-thread-1
inner 2: pool-5-thread-3
3: pool-5-thread-3
end: pool-6-thread-1
end: pool-6-thread-1
end: pool-6-thread-1
end: pool-6-thread-1
代码较长,通过颜色标记法帮我们理清线程关系
上色后一目了然了,需要特别注意的是由于flatMap中切换了数据源的同时切换了线程,所以打印3的线程不是s2 而是 s4
3.2 Flow
首相创建对应的Dispatcher
然后将代码换成Flow的写法,主要遵循下列原则
RxJava通过observeOn切换后续代码的线程
Flow通过flowOn切换前置代码的线程
打印结果如下:
1: pool-1-thread-1 @coroutine#6
1: pool-1-thread-1 @coroutine#6
1: pool-1-thread-1 @coroutine#6
2: pool-2-thread-2 @coroutine#5
2: pool-2-thread-2 @coroutine#5
2: pool-2-thread-2 @coroutine#5
inner 1: pool-3-thread-1 @coroutine#10
inner 1: pool-3-thread-2 @coroutine#11
inner 1: pool-3-thread-3 @coroutine#12
inner 1: pool-3-thread-2 @coroutine#11
inner 1: pool-3-thread-3 @coroutine#12
inner 2: pool-4-thread-3 @coroutine#9
inner 1: pool-3-thread-1 @coroutine#10
inner 1: pool-3-thread-3 @coroutine#12
inner 1: pool-3-thread-2 @coroutine#11
inner 2: pool-4-thread-1 @coroutine#7
inner 2: pool-4-thread-2 @coroutine#8
inner 2: pool-4-thread-1 @coroutine#7
inner 2: pool-4-thread-3 @coroutine#9
inner 1: pool-3-thread-1 @coroutine#10
3: pool-4-thread-1 @coroutine#3
inner 2: pool-4-thread-3 @coroutine#9
inner 2: pool-4-thread-2 @coroutine#8
end: pool-5-thread-1 @coroutine#2
3: pool-4-thread-1 @coroutine#3
inner 2: pool-4-thread-2 @coroutine#8
3: pool-4-thread-1 @coroutine#3
end: pool-5-thread-1 @coroutine#2
3: pool-4-thread-1 @coroutine#3
end: pool-5-thread-1 @coroutine#2
end: pool-5-thread-1 @coroutine#2
3: pool-4-thread-1 @coroutine#3
3: pool-4-thread-1 @coroutine#3
end: pool-5-thread-1 @coroutine#2
end: pool-5-thread-1 @coroutine#2
3: pool-4-thread-1 @coroutine#3
3: pool-4-thread-1 @coroutine#3
end: pool-5-thread-1 @coroutine#2
end: pool-5-thread-1 @coroutine#2
inner 2: pool-4-thread-1 @coroutine#7
3: pool-4-thread-1 @coroutine#3
end: pool-5-thread-1 @coroutine#2
从日志可以看到,1、2、3的时序性以及inner1和inner2的并发性与RxJava的一致。
4、FIN
Flow在线程切换方面可以完全取代RxJava的能力,而且将subscribeOn和observeOn两个操作符合二为一成flowOn,学习成本更低。随着flow的操作符种类日趋完善,未来在Android/Kotlin开发中可以跟RxJava说再见了????????
http://www.taodudu.cc/news/show-2975612.html
相关文章:
- 系列 | 数仓实践第三篇NO.3『拉链表』
- Apache拯救世界之数据质量监控工具 - Apache Griffin
- 每日学习 与 每日未知
- TCP传输
- 24 张图总结 TCP 基础知识,看完我飘了。
- 去掉Holo主题下Dialog的蓝色线
- TCP标志位syn,ack,fin以及序列号(seq),响应号(ack)
- 基于springboot的手办定制销售系统毕业设计源码031800
- SSM基于WEB的房屋出租管理系统 毕业设计-附源码261620
- springboot基于微信小程序的电器商城系统的设计与实现毕业设计源码251453
- Springboot自行车网上商城毕业设计-附源码130948
- 基于Springboot的特产销售平台设计与实现毕业设计源码091036
- springboot基于JAVA游戏周边商城设计与实现毕业设计源码261622
- Springboot游戏道具在线交易平台毕业设计源码171956
- Springboot+基于微信小程序的电器商城系统的设计与实现 毕业设计-附源码251453
- springboot罗亚方舟考研资料库网站设计与实现毕业设计源码302302
- php社区果蔬网站毕业设计源码211548
- 电商环境下中小企业客户关系管理系统设计
- 【一周头条盘点】中国软件网(2018.8.20~2018.8.24)
- 网络游戏软件销售渠道模式举例及分析
- 【渝粤题库】广东开放大学 互联网金融 形成性考核
- 超详细零信任市场解读
- 用ENSP华为模拟器做图书馆得网络配置和设计
- 新华社客户端文章:区块链金融:新蓝海还是新挑战
- 利用python进行AdaBoost模型预测
- factor java_使用randomForest,Caret和factor变量预测栅格时出错
- XGBoost参数调优完全指南(附Python代码)
- Kaggle实战(一):泰坦尼克获救预测
- 第十章 决策树与随机森林
- [论文笔记]slope one predictors for online rating-based collaborative filtering
线程切换哪家强?RxJava与Flow的操作符对比相关推荐
- 国产手机 android 6,国产手机系统哪家强?6大手机系统对比
现在手机系统基本可以分为安卓和苹果两大阵营.在这之后,安卓系统又因为手机厂商不同可以细分.可以说,几乎每一个手机品牌都在安卓系统基础上进行了优化,打造了自己的专属UI.今天小编就给大家盘点一下,现在比 ...
- 人像摄影哪家强?同为双摄的OPPO R11不敌金立S10
随着智能手机摄像头的配置不断提升,如今用手机进行拍照的大有人在,而且人像拍摄可以说是大部分人购买拍照手机的主要目的,所以人像拍摄功能也是手机厂商的必争之地,那么问题来了,人像摄影哪家强呢?今天我们就来 ...
- android rxjava 多线程,你真的了解RxJava的线程切换吗?
使用RxJava可以轻松地实现线程切换,所以在Android中常被用来替代AsyncTask.Handler等原生工具类.使用起来虽然简单,但如果不了解其背后的基本原理,很可能因为使用不当而写出bug ...
- RxJava 线程切换
前言 在上篇文章对RxJava 的工作流程进行的简单的分析,今天来分享一下线程切换的流程.如果觉得源码枯燥可以直接移至文末看图理解. 实例代码 Observable.create(new Observ ...
- 迷之RxJava —— 线程切换
RxJava最迷人的是什么? 答案就是把异步序列写到一个工作流里!和javascript的Promise/A如出一辙. OK,在java中做异步的事情在我们传统理解过来可不方便,而且,如果要让异步按照 ...
- 30 张图解 | 高频面试知识点总结:面试官问我高并发服务模型哪家强?
面试中经常会被问到高性能服务模型选择对比,以及如何提高服务性能和处理能力,这其中涉及操作系统软件和计算机硬件知识,其实都是在考察候选人的基础知识掌握程度,但如果没准备的话容易一头雾水,这次带大家 ...
- 30 张图解 | 面试官问我高并发服务模型哪家强?
面试中经常会被问到高性能服务模型选择对比,以及如何提高服务性能和处理能力,这其中涉及操作系统软件和计算机硬件知识,其实都是在考察候选人的基础知识掌握程度,但如果没准备的话容易一头雾水,这次带大家从头到 ...
- Rxjava2原理流程+操作符+线程切换 浅析~
0.前言 没拜读过强大的代码就建议去稍微看一下rxjava2的原理,并不难懂.写的非常的好,也能领略到大佬写的代码有多么的强.里面的设计模式真的牛逼 1.Rxjava2 Rxjava2用于我们来做响应 ...
- Kotlin之Flow由浅入深,对比Rxjava
原文链接 sequence sequence又被称为惰性集合操作,下面举例说明 fun main() {val sequence = sequenceOf(1, 2, 3, 4)val result: ...
最新文章
- [CTO札记]惊讶于警察尚未用LBS(手机定位服务)来追踪疑犯
- qdbus 复杂类型
- POJ 2356 (抽屉原理)
- 关于控件ID的试验(涉及MasterPage)
- 工程勘察设计管理条例释义电子书_全国有多少注册勘察设计工程师?官方数据告诉你...
- CMU提出「十字绣网络」,自动决定多任务学习的最佳共享层
- 华为笔记本matebook13_华为引领“第三代移动办公”新纪元 华为MateBook开启“智慧化办公”新赛道...
- 人民邮电出版社与作者陈黎夫共同举办在线编辑、作者交流活动
- azure 入门_Azure Function应用程序入门
- UVA 1324 The Largest Clique 最大团(强连通分量,变形)
- Qt之QListView使用
- 进程和线程的主要区别
- 百度开源的 71 个项目,太牛逼了!
- 全网软件:高级信息搜索数据采集软件 InfoSeek FastSeek
- python for ArcGIS 绘制广州市板块地图
- 戴尔服务器u盘装系统看不见磁盘,戴尔电脑u盘装系统找不到硬盘怎么解决
- HP JetDirect 170X 配置
- 汉语词典快速查询算法研究
- mysql 直方图统计_MySQL 8.0 新特性之统计直方图
- 转载---Cesium简介