5.RxJava2 线程调度器
调度器 Scheduler 用于控制操作符和被观察者事件所执行的线程,不同的调度器对应不同的线程。RxJava提供了5种调度器:
RxJava 线程调度器 | 说明 |
---|---|
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()将它入队。这个调度器将会处理它的队列并且按序运行队列中每一个任务。 |
AndroidSchedulers.mainThread() | RxAndroid 提供的,它指定的操作将在 Android 主线程运行。 |
可以使用 subscribeOn() 和 ObserveOn() 操作符进行线程调度,让 Observable 在一个特定的调度器上执行。subscribeOn() 指定 subscribe() 所发生的线程,事件产生的线程。ObserveOn() 指定 Observer 所运行在的线程,事件消费的线程。
版权声明:本文为Kevin_s_gun原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。