摘要:即在哪个线程生产事件就在哪个线程消费事件总是启用新线程,并在新线程执行操作。行为模式和差不多,区别在于的内部实现是是用一个无数量上限的线程池,可以重用空闲的线程,因此多数情况下比更有效率。这个使用的固定的线程池,大小为核数。
我们知道,RxJava最主要的特点就是异步操作,它的异步操作就是用Scheduler来指定Observable和Subscriber所运行的线程,在默认情况下,即在不指定线程的情况下,RxJava遵循的是线程不变的原则,即:在哪个线程生产事件,就在哪个线程消费事件
Schedulers线程调度器
我们来看一下Schedulers的分类:
(1)Schedulers.immediate():默认的Scheduler。即在哪个线程生产事件,就在哪个线程消费事件
(2)Schedulers.newThread():总是启用新线程,并在新线程执行操作。
(3)Schedulers.io(): I/O 操作(读写文件、读写数据库、网络信息交互等)所使用的Scheduler。行为模式和newThread()差不多,区别在于io()的内部实现是是用一个无数量上限的线程池,可以重用空闲的线程,因此多数情况下 io() 比 newThread() 更有效率。不要把计算工作放在 io() 中,可以避免创建不必要的线程。
(4)Schedulers.computation(): 计算所使用的Scheduler。这个计算指的是 CPU 密集型计算,即不会被I/O等操作限制性能的操作,例如图形的计算。这个Scheduler使用的固定的线程池,大小为 CPU 核数。不要把 I/O 操作放在 computation()
中,否则I/O操作的等待时间会浪费CPU。
(5)另外,RxAndroid 还有一个专用的 AndroidSchedulers.mainThread(),它指定的操作将在 Android 主线程运行。
1 Observable.create(new Observable.OnSubscribe(){ 2 @Override 3 public void call(Subscriber super Integer> subscriber) { 4 //后台线程取数据 5 } 6 }).subscribeOn(Schedulers.io()) //指定事件产生的线程,Observable的方法所在的线程 7 .observeOn(AndroidSchedulers.mainThread()) //指定事件消费的线程,即Subscriber所运行在的线程 8 .subscribe(new Action1 () { 9 @Override 10 public void call(Integer integer) { 11 //主线程显示数据 12 } 13 });
如何实现线程的多次控制呢?我们来看一下下面的代码
1 Observable.just(R.mipmap.ic_launcher).subscribeOn(Schedulers.io())//指定Observable的操作运行在io()中 2 .observeOn(Schedulers.newThread())//指定map运行于newThread()中 3 .map(new Func1() { 4 @Override 5 public Drawable call(Integer integer) { 6 return getResources().getDrawable(integer); 7 } 8 }).observeOn(AndroidSchedulers.mainThread())//指定Subscriber的代码运行在主线程 9 .subscribe(new Action1 () { 10 11 @Override 12 public void call(Drawable drawable) { 13 iv_iamgeview.setImageDrawable(drawable); 14 } 15 });
文章版权归作者所有,未经允许请勿转载,若此文章存在违规行为,您可以联系管理员删除。
转载请注明本文地址:https://www.ucloud.cn/yun/3087.html
摘要:即,默认情况下它会随着上游线程的切换而切换,二者始终在一个线程,除非它通过自行指定。然后就直接将这个交给线程池去执行了。即这行代码所在的线程。指定的是下游接收事件的线程即这些回调方法的执行线程。 上一篇文章Rxjava2.x源码解析(一): 订阅流程中我们讲了 RxJava2 的订阅部分的源码。但 RxJava2 最强大的部分其实是在异步。默认情况下,下游接收事件所在的线程和上游发送事...
摘要:行为模式和差不多,区别在于的内部实现是是用一个无数量上限的线程池,可以重用空闲的线程,因此多数情况下比更有效率。这个使用的固定的线程池,大小为核数。指定所发生的线程,即被激活时所处的线程。或者叫做事件产生的线程。 前言 本篇主要介绍Rxjava在 Android 项目中的基础使用和常用方法,旨在给对 RxJava 感兴趣的人一些入门的指引.对Rxjava不熟悉的朋友可以去看我之前写的一...
摘要:观察者模式面向的需求是对象观察者对对象被观察者的某种变化高度敏感,需要在变化的一瞬间做出反应。规定,当不会再有新的发出时,需要触发方法作为标志。在事件处理过程中出异常时,会被触发,同时队列自动终止,不允许再有事件发出。 我从去年开始使用 RxJava ,到现在一年多了。今年加入了 Flipboard 后,看到 Flipboard 的 Android 项目也在使用 RxJava ,并且使...
摘要:谜之二一个异步库最迷人的是什么答案就是把异步序列写到一个工作流里和的如出一辙。综上所述,如果我们需要我们的在一个别的线程上运行的时候,只需要在后面跟一个即可。 【谜之RxJava (二) —— Magic Lift】 Rxjava -- 一个异步库 RxJava最迷人的是什么?答案就是把异步序列写到一个工作流里!和javascript的Promise/A如出一辙。OK,在java中做异...
摘要:观察者模式的概念是的异步框架,官方介绍是可观测的序列,组成异步基于事件程序的库。即异步情况下,问题才会存在。消费者通过传入其需求,然后生产者把个事件传递给消费者供其消费。观察者模式的概念 RxJava是android的异步框架,官方介绍是可观测的序列,组成异步基于事件程序的库。特点是观察者模式,基于事件流的链式调用,随着异步操作调度过程复杂的情况下,程序逻辑也变得越来越复杂,但RxJava依...
阅读 512·2021-11-15 11:37
阅读 3198·2021-10-27 14:14
阅读 3254·2021-10-11 10:56
阅读 5052·2021-09-13 10:30
阅读 2839·2021-09-08 09:35
阅读 2773·2021-09-04 16:48
阅读 1756·2021-08-18 10:22
阅读 2006·2019-08-30 14:19