1.computation:

computation Scheduler適用于和CPU有關的任務,但是不適合那些會造成阻塞的任務,因為computation Scheduler內部會根據CPU核數來創(chuàng)建一個線程池,里面的每個線程會占用一個CPU的核心,從而充分利用CPU的資源;
默認運行在computation上面的操作符是: delay 、timer 、skip 、take等。

2.newThread

newThread Scheduler每次都會新建一個線程, 創(chuàng)建線程會造成稍微的延遲。(性能問題,一般不用)

3.io

io Scheduler類似newThread Scheduler , 不同在于io Scheduler的線程可以被回收利用。io Scheduler內部維持了一個線程池,如果有空閑的線程就會在空閑的線程上執(zhí)行,否則會創(chuàng)建一個新的線程,當空閑線程60秒后沒被利用,空閑線程將會被回收

4.immediate

immediate Scheduler會在當前的線程上立刻執(zhí)行任務,這會將當前線程上正在進行的任務阻塞。例如:如果用Outer代表代表當前正在執(zhí)行的任務,用Inner來代表使用immediate Scheduler的任務,執(zhí)行順序如下:
Outer start-->Inner start --> Inner end --> Outer end 一般也應該避免使用這個Scheduler。

5.trampoline

trampoline Scheduler 同 immediate Scheduler很像,都會在當前線程上執(zhí)行任務。但是trampoline 并不是立刻開始執(zhí)行任務,而是等當前線程上之前的任務執(zhí)行都結束后再開始執(zhí)行。如果用Outer 和 Inner來代表當前線程上的任務和使用trampoline Scheduler的任務,執(zhí)行順序如下: Outer start --> Outer end -->Inner start --> Inner end

6.from

當內置線程無法滿足你的需求的時候, 可以使用Schedulers.from(Executor excutor) ,根據提供的Executor來創(chuàng)建Scheduler。

public class SimpleThreadFactory implements ThreadFactory {
    @Override
    public Thread newThread(@NonNull Runnable runnable) {
        return new Thread(runnable);
    }
}

Executor executor = new ThreadPoolExecutor(
        2,
        2,
        2000L,TimeUnit.MILLISECONDS,
        new LinkedBlockingDeque<Runnable>(1000),
        new SimpleThreadFactory());

Scheduler scheduler = Schedulers.from(executor);

Observable.interval(1,TimeUnit.SECONDS).take(5)
        .observeOn(scheduler)
        .subscribe(new Action1<Long>() {
            @Override
            public void call(Long aLong) {
                Log.e("call","Thread Name: "+Thread.currentThread().getName());
            }
        });

內部創(chuàng)建了兩個線程,并且這兩個線程會被回收利用。
09-20 14:16:27.032 19128-19174/com.example.administrator.rxjavademo E/call: Thread Name: Thread-3290
09-20 14:16:28.032 19128-19153/com.example.administrator.rxjavademo E/call: Thread Name: Thread-3286
09-20 14:16:29.031 19128-19174/com.example.administrator.rxjavademo E/call: Thread Name: Thread-3290
09-20 14:16:30.039 19128-19153/com.example.administrator.rxjavademo E/call: Thread Name: Thread-3286
09-20 14:16:31.031 19128-19174/com.example.administrator.rxjavademo E/call: Thread Name: Thread-3290

..............
7.test / TestScheduler

測試調度器在 RxJava2.x 中，原先RxJava1.x的Schedulers.test()被去掉了，想要獲得TestScheduler對象可以通過直接new TestScheduler()的方式來實現。
TestScheduler讓你可以對調度器的時鐘表現進行手動微調。這對依賴精確時間安排的任務的測試很有用處。這個調度器有三個額外的方法：

• advanceTimeTo(time,unit) 向前波動調度器的時鐘到一個指定的時間點
• advanceTimeBy(time,unit) 將調度器的時鐘向前撥動一個指定的時間段
• triggerActions(?) 開始執(zhí)行任何計劃中的但是未啟動的任務，如果它們的計劃時間等于或者早于調度器時鐘的當前時間

參考:

• RxJava響應式編程
• RxJavaX GitHub
• RxJavaX 官方
• RxJavaX 中文文檔