RxJava 1.x 理解-2
2024-10-20 20:31:15
给RxJava 加入线程控制 -- Scheduler
在 RxJava 1.x 理解-1 中,我们说到了RxJava的简单用法,但是这还远远不够,因为这简单用法是在同一个线程中使用的。比如我们需要在子线程中进行耗时操作,在Android 主线程中进行UI操作,这样才不会导致卡顿的发生。
先上代码:
Observable
.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onNext("提供数据01 获取线程id:" + Thread.currentThread().getId());
subscriber.onNext("提供数据02 获取线程id:" + Thread.currentThread().getId());
subscriber.onNext("提供数据03 获取线程id:" + Thread.currentThread().getId());
subscriber.onNext("提供数据04 获取线程id:" + Thread.currentThread().getId());
}
})
.subscribeOn(Schedulers.io()) // 订阅发生在 // 指定 subscribe() 发生在 IO 线程
.observeOn(AndroidSchedulers.mainThread()) // 观察发生在 // 指定 Subscriber 的回调发生在主线程
.subscribe(new Action1<String>() {
@Override
public void call(String s) {
Log.d(TAG, "Item: " + s + " 执行调用 获取线程id:" + Thread.currentThread().getId());
}
});
输入的结果:
02-08 22:19:04.212 6071-6071/pers.bolin.rxjavademo D/MainActivity: Item: 提供数据01 获取线程id:6091 / 执行调用 获取线程id:2
02-08 22:19:04.212 6071-6071/pers.bolin.rxjavademo D/MainActivity: Item: 提供数据02 获取线程id:6091 / 执行调用 获取线程id:2
02-08 22:19:04.212 6071-6071/pers.bolin.rxjavademo D/MainActivity: Item: 提供数据03 获取线程id:6091 / 执行调用 获取线程id:2
02-08 22:19:04.212 6071-6071/pers.bolin.rxjavademo D/MainActivity: Item: 提供数据04 获取线程id:6091 / 执行调用 获取线程id:2
可以看出提供数据的事件发生在IO线程中,而回调的事件发生在主线程中了。
在RxJava 中,Scheduler
——调度器,相当于线程控制器,RxJava 通过它来指定每一段代码应该运行在什么样的线程。RxJava 已经内置了几个 Scheduler
,它们已经适合大多数的使用场景:
Schedulers.immediate()
: 直接在当前线程运行,相当于不指定线程。这是默认的Scheduler
。Schedulers.newThread()
: 总是启用新线程,并在新线程执行操作。Schedulers.io()
: I/O 操作(读写文件、读写数据库、网络信息交互等)所使用的Scheduler
。行为模式和newThread()
差不多,区别在于io()
的内部实现是是用一个无数量上限的线程池,可以重用空闲的线程,因此多数情况下io()
比newThread()
更有效率。不要把计算工作放在io()
中,可以避免创建不必要的线程。Schedulers.computation()
: 计算所使用的Scheduler
。这个计算指的是 CPU 密集型计算,即不会被 I/O 等操作限制性能的操作,例如图形的计算。这个Scheduler
使用的固定的线程池,大小为 CPU 核数。不要把 I/O 操作放在computation()
中,否则 I/O 操作的等待时间会浪费 CPU。- 另外, Android 还有一个专用的
AndroidSchedulers.mainThread()
,它指定的操作将在 Android 主线程运行。
有了这几个 Scheduler
,就可以使用 subscribeOn()
和 observeOn()
两个方法来对线程进行控制了。 * subscribeOn()
: 指定 subscribe()
所发生的线程,即 Observable.OnSubscribe
被激活时所处的线程。或者叫做事件产生的线程。 * observeOn()
: 指定 Subscriber
所运行在的线程。或者叫做事件消费的线程。
参考资料:
最新文章
- Windows出现带空格文件名无法删除
- RDS记录
- 从inet_pton()看大小端字节序
- ArrayAdapter与SimpleAdapter的使用
- 数据库性能之--ibatis cache应用
- RAC 移动 OCR
- 无法debug断点跟踪JDK源代码——missing line number attributes的解决方法
- Linux Oracle碰到错误:ORA-27101: shared memory realm does not exist
- Android View的绘制机制流程深入详解(四)
- (原) Jquery 判断移动设备是IOS / Android系统
- Myeclipse8.6安装freemarker插件
- vijos1027题解
- 使用python实现计算器功能
- 洛谷 P3674 小清新人渣的本愿 [莫队 bitset]
- 3,列表的 深 浅 copy
- 29.python环境搭建
- css中display:none与visibility: hidden的区别
- Python 全栈开发六 常用模块学习
- C BIN加密
- 4-圆数Round Numbers(数位dp)
热门文章
- vue之axios使用
- Web应用程序开发,基于Ajax技术的JavaScript树形控件
- [codevs3160]最长公共子串解题报告|后缀自动机
- 在Xcode5下实现4.5,4.6的效果
- Ring0层创建事件,Ring3层接收
- 复选框回显、全选、非全选、cookie处理数据、json数组对象转换处理学习笔记参考的页面
- 【计算机网络】wireshark抓包分析2
- python 金字塔图形
- could not find or load the Qt platform plugin ";xcb";
- [BZOJ1316]树上的询问 点分治