1、线程调度subscribeOn的设置方法如下

RxJava2——2之线程调度

查看subscribeOn方法如下

RxJava2——2之线程调度

ObservableSubscribeOn类间接的继承了Observable类,其中构造方法和subscribeActual方法如下

RxJava2——2之线程调度

SubscribeTask为ObservableSubscribeOn的内部类,其中source为创建的Observable对象(即ObservableSubscribeOn),parent指的是SubscribeOnObserver

RxJava2——2之线程调度

SubscribeOnObserver为ObservableSubscribeOn的内部类,其中onNext,onError,onComplete与new Observer的方法相对应。

RxJava2——2之线程调度

RxJava2——2之线程调度

在ObservableSubscribeOn类的SubscribeActual方法有下述代码指定线程

RxJava2——2之线程调度

Scheduler类的scheduleDirect方法

RxJava2——2之线程调度

RxJava2——2之线程调度

在Worker的线程开始执行任务。

相关文章:

  • 2021-11-25
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
  • 2021-05-19
  • 2022-12-23
  • 2021-11-10
  • 2021-12-27
猜你喜欢
  • 2021-12-27
  • 2022-02-20
  • 2022-12-23
  • 2021-07-06
  • 2022-12-23
  • 2021-08-29
  • 2022-12-23
相关资源
相似解决方案