之前我也用到過執行緒排程,但是沒有仔細講這個問題,我這裡作為新手還是解釋一下
/**
* 執行緒排程一:基本配置
* 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 ...