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 中文文档
