Scheduler(一)

1.Scheduler 的 API

在响应式编程中,如果想给Observable操作符链添加多线程功能,可以指定操作符(或者特定的Observable)在特定的调度器(Scheduler)上执行。

RxJava提供了5种调度器:

Schedulers.immediate():这个调度器允许立即在当前线程执行所指定的工作。它是默认的调度器。

Schedulers.newThread():总是启用新线程,并在新线程执行操作。

Schedulers.io():这个调度器适用于I/O操作。它基于根据需要,增长或缩减来自适应的线程池。因此多数情况下 io() 比 newThread() 更有效率。不要把计算工作放在 io() 中,可以避免创建不必要的线程。

Schedulers.computation():这个是计算工作默认的调度器,这个计算指的是 CPU 密集型计算,即不会被 I/O 等操作限制性能的操作。这个 Scheduler 使用的固定的线程池,大小为 CPU 核数。不要把 I/O 操作放在 computation() 中,否则 I/O 操作的等待时间会浪费 CPU。

Schedulers.trampoline():当我们想在当前线程执行一个任务时,并不是立即,我们可以用.trampoline()将它入队。这个调度器将会处理它的队列并且按序运行队列中每一个任务。

补充:Android 还有一个专用的 AndroidSchedulers.mainThread(),它指定的操作将在 Android 主线程运行。

那么如何进行线程调度呢?

可以使用ObserveOn()和subscribeOn()操作符,让Observable在一个特定的调度器上执行。

subscribeOn()指定 subscribe()所发生的线程,即 Observable.OnSubscribe 被激活时所处的线程。或者叫做事件产生的线程。

observeOn()指定 Subscriber 所运行在的线程。或者叫做事件消费的线程。

2.举个栗子(代码演示)

通过url从网络上获取一张图片,并显示在imageView中。网络请求是消耗时间长,需要放在后台线程,更新UI需要在主线程执行。

Observable.getBitmapFromNet(url).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(bitmap->imageView.setImageBitmap(bitmap));

补充:Scheduler切换线程中,通过 observeOn() 的多次调用,程序可以在线程间多次切换。而subscribeOn() 只能调用一次的,它可以放在任何位置。

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 我从去年开始使用 RxJava ,到现在一年多了。今年加入了 Flipboard 后,看到 Flipboard 的...
    Jason_andy阅读 5,561评论 7 62
  • 转一篇文章 原地址:http://gank.io/post/560e15be2dca930e00da1083 前言...
    jack_hong阅读 940评论 0 2
  • 最近项目里面有用到Rxjava框架,感觉很强大的巨作,所以在网上搜了很多相关文章,发现一片文章很不错,今天把这篇文...
    Scus阅读 6,894评论 2 50
  • 前言我从去年开始使用 RxJava ,到现在一年多了。今年加入了 Flipboard 后,看到 Flipboard...
    占导zqq阅读 9,177评论 6 151
  • 除了code,还有生活
    BlackWingXu阅读 114评论 0 0