RxJava学习笔记2
2016-03-15 15:54
225 查看
上一篇RxJava学习笔记1只是介绍了RxJava最基本的使用方法,但是RxJava核心是异步,上篇所有的操作默认是在同一个线程中进行操作,下面我们介绍RxJava中一个比较核心的概念:
Scheduler ->>>>>>用于线程调度
不指定线程的情况下, RxJava 原则是运行在同一个线程里,
即:在调用 subscribe()的线程中,生产事件,消费事件。
如果需要指定线程,就需要用到 Scheduler (线程调度器)。
系统已经内置了几个调度器,能够完成大部分的线程调度工作
Schedulers.immediate(): 直接在当前线程运行,相当于不指定线程。这是默认的 Scheduler。
Schedulers.newThread(): 每次都启动新线程,在新线程执行。
Schedulers.io(): I/O 操作(读写文件、读写数据库、网络信息交互等)。
行为模式和 newThread() 差不多,区别在于 io() 的内部实现是是用一个无数量上限的线程池,可以重用空闲的线程,因此多数情况下 io() 比 newThread() 更有效率。不要把计算工作放在 io() 中,可以避免创建不必要的线程。
Schedulers.computation(): 计算所使用的 Scheduler。这个计算指的是 CPU 密集型计算,即不会被 I/O 等操作限制性能的操作,
例如图形的计算。这个 Scheduler 使用的固定的线程池,大小为 CPU 核数。不要把 I/O 操作放在 computation() 中,否则 I/O 操作的等待时间会浪费 CPU。
Android 还有一个专用的 AndroidSchedulers.mainThread(),它指定的操作将在 Android 主线程运行。
线程控制的两个方法:
subscribeOn() 指定 subscribe() 所发生的线程,即 Observable.OnSubscribe 被激活时所处的线程。或者叫做事件产生的线程。
observeOn() 指定 Subscriber 所运行在的线程。或者叫做事件消费的线程。
线程的调度使用就是这么简单,至于原理请看下一张
Scheduler ->>>>>>用于线程调度
不指定线程的情况下, RxJava 原则是运行在同一个线程里,
即:在调用 subscribe()的线程中,生产事件,消费事件。
如果需要指定线程,就需要用到 Scheduler (线程调度器)。
系统已经内置了几个调度器,能够完成大部分的线程调度工作
Schedulers.immediate(): 直接在当前线程运行,相当于不指定线程。这是默认的 Scheduler。
Schedulers.newThread(): 每次都启动新线程,在新线程执行。
Schedulers.io(): I/O 操作(读写文件、读写数据库、网络信息交互等)。
行为模式和 newThread() 差不多,区别在于 io() 的内部实现是是用一个无数量上限的线程池,可以重用空闲的线程,因此多数情况下 io() 比 newThread() 更有效率。不要把计算工作放在 io() 中,可以避免创建不必要的线程。
Schedulers.computation(): 计算所使用的 Scheduler。这个计算指的是 CPU 密集型计算,即不会被 I/O 等操作限制性能的操作,
例如图形的计算。这个 Scheduler 使用的固定的线程池,大小为 CPU 核数。不要把 I/O 操作放在 computation() 中,否则 I/O 操作的等待时间会浪费 CPU。
Android 还有一个专用的 AndroidSchedulers.mainThread(),它指定的操作将在 Android 主线程运行。
线程控制的两个方法:
subscribeOn() 指定 subscribe() 所发生的线程,即 Observable.OnSubscribe 被激活时所处的线程。或者叫做事件产生的线程。
observeOn() 指定 Subscriber 所运行在的线程。或者叫做事件消费的线程。
//示例代码 Observable.just(T t) .subscribeOn(Schedulers.io()) // 指定 subscribe() 发生在 IO 线程 .observeOn(AndroidSchedulers.mainThread()) // 指定 Subscriber 的回调发生在主线程 .subscribe(new Action1<T t>() { public void call(T t) {}}); //这是很常见的一个操作 //例如 我们从后台联网获取数据 然后成功之后在主线程中对界面进行UI显示
线程的调度使用就是这么简单,至于原理请看下一张
相关文章推荐
- 【leetcode】【198】House Robber
- 使用FileChannel(文件通道)来实现文件快速复制
- Eclipse优化常用方法
- R.java文件介绍
- spring 整合 ActiveMQ
- Spring的注解
- SpringMVC访问静态资源的三种方式
- Eclipse - 安装 run-jetty-run 插件及使用 jrebel 热部署
- 【leetcode】【191】Number of 1 Bits
- java,多线程实现
- Spring学习8-Spring事务管理
- Java报表工具FineReport导出EXCEL的四种API
- 【leetcode】【190】Reverse Bits
- loadCache之实习那些事
- 如果需要修改表格,在eclipse 中需要做什么操作
- 使用eclipse直接生成so文件
- Java-异常
- 冒泡排序和快速排序java实现
- Java 8的新特性—终极版
- spring hibernate摘记