1、线程调度subscribeOn的设置方法如下
查看subscribeOn方法如下
ObservableSubscribeOn类间接的继承了Observable类,其中构造方法和subscribeActual方法如下
SubscribeTask为ObservableSubscribeOn的内部类,其中source为创建的Observable对象(即ObservableSubscribeOn),parent指的是SubscribeOnObserver
SubscribeOnObserver为ObservableSubscribeOn的内部类,其中onNext,onError,onComplete与new Observer的方法相对应。
在ObservableSubscribeOn类的SubscribeActual方法有下述代码指定线程
Scheduler类的scheduleDirect方法
在Worker的线程开始执行任务。