RxJava2簡單使用三(執行緒排程)

2021-07-30 00:21:01 字數 389 閱讀 3886

之前我也用到過執行緒排程,但是沒有仔細講這個問題,我這裡作為新手還是解釋一下

/**

* 執行緒排程一:基本配置

* subscribeon(schedulers.newthread()),將被觀察者設定在乙個新的執行緒來執行

* observeon(androidschedulers.mainthread()),將觀察者設定在主線程執行

* subscribe(consumer),被觀察者註冊觀察者

*/observable.subscribeon(schedulers.newthread())

.observeon(androidschedulers.mainthread())

.subscribe(consumer);

RxJava2實現執行緒切換

被觀察者 observable 觀察者 observer 訂閱 subscribe 1 建立被觀察者 observable observable observable.create new observableonsubscribe 2 建立觀察者 observer observer new obs...

Rxjava2的簡單實用

第一種方式實現觀察者和被觀察者的建立和建立聯絡 1 建立被觀察者 建立被觀察者 傳送資料 observable observable observable.create new observableonsubscribe 2 建立觀察者 建立觀察者 接受資料 io.reactivex.observe...

RxJava2(五)執行緒排程器Scheduler

scheduler可排程的執行緒有 single 定長為1的執行緒池 singledthreadexecutor 復用這個執行緒。newthread 啟動一條新執行緒,並在其中進行操作。computation 固定執行緒池 fixedthreadpool n 大小為cpu數,適合與密集型計算。io ...