RxJava--Scheduler线程调度

1.computation:

computation Scheduler适用于和CPU有关的任务,但是不适合那些会造成阻塞的任务,因为computation Scheduler内部会根据CPU核数来创建一个线程池,里面的每个线程会占用一个CPU的核心,从而充分利用CPU的资源;
默认运行在computation上面的操作符是: delay 、timer 、skip 、take等。

2.newThread

newThread Scheduler每次都会新建一个线程, 创建线程会造成稍微的延迟。(性能问题,一般不用)

3.io

io Scheduler类似newThread Scheduler , 不同在于io Scheduler的线程可以被回收利用。io Scheduler内部维持了一个线程池,如果有空闲的线程就会在空闲的线程上执行,否则会创建一个新的线程,当空闲线程60秒后没被利用,空闲线程将会被回收

4.immediate

immediate Scheduler会在当前的线程上立刻执行任务,这会将当前线程上正在进行的任务阻塞。例如:如果用Outer代表代表当前正在执行的任务,用Inner来代表使用immediate Scheduler的任务,执行顺序如下:
Outer start-->Inner start --> Inner end --> Outer end 一般也应该避免使用这个Scheduler。

5.trampoline

trampoline Scheduler 同 immediate Scheduler很像,都会在当前线程上执行任务。但是trampoline 并不是立刻开始执行任务,而是等当前线程上之前的任务执行都结束后再开始执行。如果用Outer 和 Inner来代表当前线程上的任务和使用trampoline Scheduler的任务,执行顺序如下: Outer start --> Outer end -->Inner start --> Inner end

6.from

当内置线程无法满足你的需求的时候, 可以使用Schedulers.from(Executor excutor) ,根据提供的Executor来创建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());
            }
        });

内部创建了两个线程,并且这两个线程会被回收利用。
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( ) 开始执行任何计划中的但是未启动的任务，如果它们的计划时间等于或者早于调度器时钟的当前时间

参考:

• RxJava响应式编程
• RxJavaX GitHub
• RxJavaX 官方
• RxJavaX 中文文档