RxJava调度选择

栏目: Java · 发布时间: 6年前

内容简介:在RxJava中有前3个Scheduler解释的非常到位,对很棒的问题,我认为文档可以提供更多细节。

在RxJava中有 5种不同的调度程序 可供选择:

  1. immediate() :创建并返回一个在当前线程上立即执行工作的Scheduler。
  2. trampoline() :创建并返回一个Scheduler ,该Scheduler 所在线程并不会立即工作,而是要等待我们所设定的等待时间结束后才可以执行(默认为0),当然,这个延时设置是要设定在Runnable实现内部。还有一点就是所有任务要添加到一个队列中,然后依次执行即可。
  3. newThread() :创建并返回一个Scheduler,为每个任务创建一个新的Thread。
  4. computation() :创建并返回用于计算工作的Scheduler。它可以用于事件循环,处理回调和其他计算工作。注意不要使用该Scheduler执行IO类型的工作,对此,我们可以使用 io() 代替。
  5. io() :创建并返回一个用于IO类型工作的Scheduler。该实现维护了一个Executor线程池,该线程池可根据需要增长。该Scheduler可用于异步执行阻塞IO。不要使用该Scheduler执行计算任务。

问题:

前3个Scheduler解释的非常到位,对 computation()io() 有点困惑。

  1. 究竟什么是“IO-bound work”?它适用于处理streams( java.io )和files( java.nio.files )吗?适用于数据库查询吗?适用于下载文件还是访问REST API?
  2. computation()newThread() 有什么不同之处?
  3. 为什么在进行IO任务时调用 computation() 会很糟糕?
  4. 为什么在进行计算任务时调用 io() 会很糟糕?

    答案:

很棒的问题,我认为文档可以提供更多细节。

  1. io() 由无限制线程数量的线程池支持,用于执行非计算密集型任务,这些任务不会对CPU造成太大负担(比如主板上的南北桥芯片,南桥芯片主要负责软驱、硬盘、键盘以及附加卡的数据交换)。因此,与文件系统的交互,与不同主机上的数据库或服务的交互就是很好的适用场景。
  2. computation() 由有限数量的线程池支持,其大小等于可用处理器的数量。如果你试图在可用处理器之外并行安排cpu密集型工作(比如使用 newThread() ),那么当线程争夺处理器时,你就会面临线程创建开销和上下文切换开销,并且它可能会受到很大的性能影响。
  3. 最好只留下 computation() CPU密集型工作,否则你将无法获得良好的CPU利用率。
  4. io() 根据 2 中所讲,在进行计算任务时使用 io() 是很不好的,如果你 io() 并行安排了一千个计算任务,那么这千个任务中的每一个都将拥有自己的线程并争夺CPU产生的上下文切换成本。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

艾伦•图灵传

艾伦•图灵传

(英)安德鲁·霍奇斯 / 孙天齐 / 湖南科学技术出版社 / 2012-8-1 / 68.00元

《艾伦·图灵传:如谜的解谜者》是图灵诞辰100周年纪念版,印制工艺更为精美。本书是世界共认的最权威的图灵传记。艾伦?图灵是现代人工智能的鼻祖,在24岁时奠定了计算机的理论基础。二战期间,他为盟军破译密码,为结束战争做出巨大贡献。战后,他开创性地提出人工智能的概念,并做了大量的前期工作。因同性恋问题事发,被迫注射激素,后来吃毒苹果而死。作者是一名数学家,也是一名同性恋者。他对图灵的生平有切身的体会,......一起来看看 《艾伦•图灵传》 这本书的介绍吧!

RGB转16进制工具
RGB转16进制工具

RGB HEX 互转工具

HTML 编码/解码
HTML 编码/解码

HTML 编码/解码

SHA 加密
SHA 加密

SHA 加密工具