首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

Rxjava 线程切换原理

前言 rxjava 可以很方便的进行线程切换, 那么rxjava是如何进行线程切换的呢?阅读本文可以了解下rxjava 是如何进行线程切换的及线程切换的影响点。...WanRxjava ", "onComplete td ==" + Thread.currentThread().getName()); } }); 如上代码,实现了线程切换和观察者被观察者绑定的逻辑...调用Observer.OnSubscribe 方法是 不受线程调度影响的 b.subscribeOn 影响的是发送事件的线程 c.observerOn 影响的是观察者处理接受数据的线程,如果没有调用observeOn...则不会进行包装成 ObserveOnObserver,也就是说不会执行观察者的线程切换,和 发送者的线程一致 d.多次调用subscribeOn切换线程,每次都会new ObservableSubscribeOn...,触发事件发送时会往上调用,也就是第一次调用的subscribeOn传入的线程 会执行发送事件,后面的线程切换无效 e.Observer.OnSubscribe 只会执行一次,因为调用DisposableHelper.setOnce

1.2K00
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    【EventBus】事件通信框架 ( 发送事件 | 判断发布线程是否是主线程 | 子线程切换线程 | 主线程切换线程 )

    , 则需要判定发布线程是否是主线程 ; 如果发布线程是主线程 , 则切换到子线程执行订阅方法 ; 如果发布线程不是主线程 , 则直接执行订阅方法 ; 可参考 【Android 异步操作】Android...线程切换 ( 判定当前线程是否是主线程 | 子线程中执行主线程方法 | 主线程中执行子线程方法 ) 博客的部分操作 ; 一、根据不同的线程模式进行不同的线程切换操作 ---- 首先 , 获取当前线程是否是主线程...: 参考 【Android 异步操作】Android 线程切换 ( 判定当前线程是否是主线程 | 子线程中执行主线程方法 | 主线程中执行子线程方法 ) 一、判定当前线程是否是主线程 博客章节 ;...】Android 线程切换 ( 判定当前线程是否是主线程 | 子线程中执行主线程方法 | 主线程中执行子线程方法 ) 二、子线程中执行主线程方法 博客章节 ; case MAIN...分支进行合并处理 ; 参考 【Android 异步操作】Android 线程切换 ( 判定当前线程是否是主线程 | 子线程中执行主线程方法 | 主线程中执行子线程方法 ) 三、主线程中执行子线程方法

    61510

    RxJava源码浅析(三): subscribeOn线程切换和多次切换

    一、subscribeOn 这篇不仅看下subscribeOn线程切换本身,我们还要研究下多次subscribeOn为啥只有第一次有效。...(顺便说下,如果切换其他线程,比如subscribeOn(Schedulers.io()),那他最终创建的是IoScheduler类,是不是很好记。)...主线程还是新线程?...上面执行了两次subscribeOn,第一次会把订阅放在新线程中,第二次会把订阅放在主线程中,最终订阅是在主线程中执行。...三、总结 对于OnSubscribe方法而言,不管subscribeOn怎么切换线程,他都不受影响,他是最先开始执行的且只执行一次,只针对最下游有效,对于订阅而言,线程切换只是改变当前observer的所属线程

    1.9K50

    RxJava源码浅析(四): observeOn线程切换和多次切换

    上篇文章RxJava源码浅析(三): subscribeOn线程切换和多次切换 我们清楚了subscribeOn线程切换,对于Rxjava线程切换原理有了大致的理解。...subscribeOn线程切换,是整个订阅流程线程切换,而observeOn只是针对下游线程切换。 这篇我们来看下observeOn切换线程以及他多次切换的影响。...接着调用source.subscribe(newObserveOnObserver(observer, w, delayError, bufferSize));这句话我们读出信息:订阅流程的上游没有切换线程...,下游ObserveOnObserver切换线程。...总结下,observeOn就是把下游切换线程,相比subscribeOn好理解些。 二、多次observeOn 如果我们多次调用observeOn呢?是以哪个为准呢?

    1.1K10

    再忆RxJava---线程切换

    重新看一下,一来作为回顾,二来也算是学习一下3.0 在了解线程切换前,先回顾一下简单的同步操作 1.同步 Observable.create(new ObservableOnSubscribe...,启动一个线程处理我们自己写的subscribe方法。...异步线程切换流程图.png 简单来说,就是把所有的操作从右到左包装成一对观察者与被观察者的关系,然后通过发射器使所有的操作连续执行 4 流程举例 4.1 下载并显示图片 创建CreateEmitter,...,subscribe方法在IoScheduler线程中,很明显,其实是有效的,确实切换了。...其实也很好理解,我们的操作在A线程中执行,而A在线程B中执行,请问,我们的操作在哪个线程中执行?肯定是A啊(说B其实也没错,但是从学术角度来讲不准确)。

    51210

    协程简单上手(线程切换

    调度程序也就是launch和async的函数主体会运行在哪个线程中。...比如launch(Dispatchers.IO){ //协程主体函数}Dispatchers.IO 指示此协程应在为 I/O 操作预留的线程上执行。那么当协程内部还需要切换线程的时候呢?...典型的场景比如开启协程获取数据需要进行不同的线程切换:这时候可以使用withContextwithContext(Dispatchers.IO) {            // IO线程运行       ...}当withContext运行完成之后会自动恢复调用withContext的线程中。...由于多线程下的测试是不可预测的,所以正式编码中出现的withContext切换线程应换成单线程的方式因为这样将会**使得结果可预测**,所以再项目中不能使用硬编码去设置调度器Dispatchers,应该使用注入的方式如果是测试注入

    48050

    线程上下文切换

    文章目录 前言 上下文切换 上下文切换会消耗资源吗? 如何减少上下文切换导致额外的开销 前言 曾经有一份丰厚的报酬摆在我面前,我没有珍惜。直到失去之后我才意识到,我可以会写线程上下文切换。...我们具体看一下切换过程: 1、挂起当前任务(线程/进程),将这个任务在 CPU 中的状态(上下文)存储于内存中的某处 2、恢复一个任务(线程/进程),在内存中检索下一个任务的上下文并将其在 CPU 的寄存器中恢复...是因为线程上下文切换导致额外的开销。...在Linux系统下可以使用vmstat命令来查看上下文切换的次数(上一篇讲过这个) ---- 如何减少上下文切换导致额外的开销 减少上下文切换次数便可以提高多线程的运行效率。...减少上下文切换的方法有无锁并发编程、CAS算法、避免创建过多的线程和使用协程。 1、无锁并发编程:当任何特定的运算被阻塞的时候,所有CPU可以继续处理其他的运算。

    82410

    Java多线程--线程各状态如何进行切换

    首先要说的是线程状态,了解了线程状态以及状态切换的过程基本上就了解了多线程线程的状态 1、新建状态(New):新创建了一个线程对象。...两种方法均需执行线程的start()方法为线程分配必须的系统资源、调度线程运行并执行线程的run()方法。...线程的优先级及设置 线程的优先级是为了在多线程环境中便于系统对线程的调度,优先级高的线程将优先执行。 一个线程的优先级设置遵从以下原则: 线程创建时,子继承父的优先级。...”,这里需要理解的就是该线程是指的主线程等待子线程的终止。...join()方法的必要性 在很多情况下,主线程生成并起动了子线程,如果子线程里要进行大量的耗时的运算,主线程往往将于子线程之前结束,但是如果主线程处理完其他的事务后,需要用到子线程的处理结果,也就是主线程需要等待子线程执行完成之后再结束

    1.6K20

    谈谈多线程的上线文切换

    线程数量设置太小,会导致程序不能充分地利用系统资源;线程数量设置太大,又可能带来资源的过度竞争,导致上下文切换带来额外的系统开销,今天我们就来谈下线程的上线文切换。...上下文切换的诱因 在操作系统中,上下文切换的类型还可以分为进程间的上下文切换线程间的上下文切换。...而在多线程编程中,我们主要面对的就是线程间的上下文切换导致的性能问题,下面我们就重点看看究竟是什么原因导致了多线程的上下文切换。开始之前,先看下系统线程的生命周期状态。...通过线程的运行状态以及状态间的相互切换,我们可以了解到,多线程的上下文切换实际上就是由多线程两个运行状态的互相切换导致的。...总结 上下文切换是多线程编程性能消耗的原因之一,而竞争锁、线程间的通信以及过多地创建线程等多线程编程操作,都会给系统带来上下文切换。除此之外,I/O阻塞以及JVM的垃圾回收也会增加上下文切换

    21440

    关于进程和线程---对比--切换开销

    问题 一 进程和线程的对比 二 为什么进程切换开销大,线程切换开销低呢?...一 进程和线程的对比 几个方面对比: 根本区别:进程是操作系统资源分配的基本单位,而线程是任务调度和执行的基本单位 开销方面:每个进程都有独立的代码和数据空间(程序上下文),程序之间的切换会有较大的开销...;线程可以看做轻量级的进程,同一类线程共享代码和数据空间,每个线程都有自己独立的运行栈和程序计数器(PC),线程之间切换的开销小。...,除了CPU外,系统不会为线程分配内存(线程所使用的资源来自其所属进程的资源),线程组之间只能共享资源。...包含关系: 操作系统中的每一个进程中都至少存在一个线程,一个进程可拥有多个线程,一个线程只属于一个进程,线程也被称为轻权进程或者轻量级进程. 二 为什么进程切换开销大,线程切换开销低呢?

    1.6K20

    用户级多线程切换原理

    内核级线程,顾名思义,它的调度是依赖于操作系统的,即操作系统控制着内核级线程切换,比如有A和B两个内核级线程,我们用户是不知道先执行哪个线程的代码和不知道什么时候切换到另一个线程执行代码的,这件事只有操作系统知道...用户级线程 我们举例子,来进一步说明用户级线程切换的底层原理,还是记住那句话:用户级线程切换是由我们用户来主动控制的。 现在我们假设有线程1和线程2两个线程(图中红色的数字为内存的地址) ?...那么图中还有一个Yield()函数到底是什么东西呢,简单来说它就是我们用户主动来控制线程切换的一个函数,在线程1中调用Yield()函数,此时会切换线程2,在线程2中调用了Yield()函数,此时又会回到线程...,此时即进行了线程切换。...这一节,我们讲述了内核级线程和用户级线程的基本概念与区别、用户级线程切换底层原理。

    2.6K30

    Shopee 送命题:进程切换为什么比线程切换

    注意这里问的是为什么进程切换线程慢,而不是问为什么进程比线程慢。当然这里的线程肯定指的是同一个进程中的线程。 老规矩,背诵版在文末。...至此,上述这一套 CPU 生成虚拟地址并进行地址翻译的流程就是虚拟寻址(virtual addressing): 进程切换为什么比线程切换慢?...是的,进程切换会涉及到虚拟地址空间的切换,而这正是导致进程切换线程切换慢的原因所在!...而线程切换呢,由于不涉及虚拟地址空间的切换,也就不存在这个问题了。 ---- 最后放上这道题的背诵版: 面试官:进程切换为什么比线程切换要慢呢?...然后,正是因为 TLB 这个东西,导致了进程切换线程切换慢。

    64120

    内核地址空间大冒险4:线程切换

    线程调度 进入schedule()后,迎面走来一位发须皆已花白的长者。 ? “小伙子,这是要来休息了,我是负责线程调度的使者,让我看下你占用的CPU号码”,一边说一边查找着什么。...“先生您好,您来此想必是要寻找接班线程吧”,见我到来,美女起身招呼。...struct list_head cfs_tasks; }; 美女拿着rq一阵端详,说到:“您运气不错哦,rq->nr_running和rq->cfs.h_nr_running相等,看来没有实时线程,全是普通线程...你告诉我一下,下次来我就知道了” “不相等的话那就说明就绪队列里除了普通线程还有其他优先级更高的线程,就得按照优先级从stop_sched_class窗口挨个向后询问,直到找到一个线程。...不过我在这干了这么久,就实时线程所在的rt_sched_class窗口和普通线程所在的fair_sched_class最常用”,美女耐心的给我解释到。

    87620

    扫码

    添加站长 进交流群

    领取专属 10元无门槛券

    手把手带您无忧上云

    扫码加入开发者社群

    相关资讯

    热门标签

    活动推荐

      运营活动

      活动名称
      广告关闭
      领券