?RxJava中的線程轉換主要通過下面兩個方法：

1.subscribeOn

2.observeOn

一、subscribeOn

1.調用一次subscribeOn時：

Observable observable; Schedulers schedulers; Observer observer; observable.subscribeOn(schedulers).subscribe(observer)

通過解析源碼可轉化為：

observer.onSubscribe(); schedulers線程{observable.subscribe(observer) }

在原線程調用observer的onSubscribe 方法，并在schedulers的線程中調用observable 的subscribe 方法。

?

2.當多次調用subscribeOn時：

Observable observable; Schedulers schedulers1; Schedulers schedulers2; Observer observer; observable.subscribeOn(schedulers1).subscribeOn(schedulers2).subscribe(observer)

可轉化為：

observer.onSubscribe(); schedulers2線程{schedulers1線程{observable.subscribe(observer)} }

所以subscribOn只有第一次有效。

二、observeOn

1.調用一次observeOn

Observable observable; Schedulers schedulers; Observer observer; observable.observeOn(schedulers).subscribe(observer)

可轉化為：

observer.onSubscribe(); schedulers線程{observer.next()observer.complete() }

?

當多次調用observeOn時：

Observable observable; Schedulers schedulers1; Schedulers schedulers2; Observer observer; observable.observeOn(schedulers1).observeOn(schedulers2).subscribe(observer)

可轉化為：

observer.onSubscribe(); schedulers1線程{schedulers2線程{observer.next()observer.complete()} }

?

當時用map操作符時：

observable.map().observeOn(schedulers1).map(function).observeOn(schedulers2).subscribe(observer)

可轉化為：

observer.onSubscribe(); schedulers1線程{function.apply()schedulers2線程{observer.next()observer.complete()} }

?

轉載于:https://www.cnblogs.com/zhisuoyu/p/5731780.html

創作挑戰賽新人創作獎勵來咯，堅持創作打卡瓜分現金大獎

總結

以上是生活随笔為你收集整理的RxJava线程控制的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。