摘要:指定所發生的線程,即被激活時所處的線程。它指定的操作將在主線程運行。也就是說,的處理和最后的消費事件都會在線程中執行。
前言
經過前幾篇的介紹,對RxJava對模式有了一定的理解:由Observable發起事件,經過中間的處理后由Observer消費。(對RxJava還不了解的可以出門左拐)
之前的代碼中,事件的發起和消費都是在同一個線程中執行,也就是說之前我們使用的RxJava是同步的~~~
觀察者模式本身的目的不就是后臺處理,將處理結果回調給前臺?這同步的是要哪樣?所以,這篇為大家介紹RxJava的重要的概念——Scheduler
參考:給 Android 開發者的 RxJava 詳解介紹
(本文部分內容引用自該博客)
RxJava在不指定線程的情況下,發起時間和消費時間默認使用當前線程。所以之前的做法
Observable.just(student1, student2, student2) //使用map進行轉換,參數1:轉換前的類型,參數2:轉換后的類型 .map(new Func1() { @Override public String call(Student i) { String name = i.getName();//獲取Student對象中的name return name;//返回name } }) .subscribe(new Action1 () { @Override public void call(String s) { nameList.add(s); } });
因為是在主線程中發起的,所以不管中間map的處理還是Action1的執行都是在主線程中進行的。若是map中有耗時的操作,這樣會導致主線程擁塞,這并不是我們想看到的。
SchedulerScheduler:線程控制器,可以指定每一段代碼在什么樣的線程中執行。
模擬一個需求:新的線程發起事件,在主線程中消費
private void rxJavaTest3() { Observable.just("Hello", "Word") .subscribeOn(Schedulers.newThread())//指定 subscribe() 發生在新的線程 .observeOn(AndroidSchedulers.mainThread())// 指定 Subscriber 的回調發生在主線程 .subscribe(new Action1() { @Override public void call(String s) { Log.i(TAG, s); } });
上面用到了subscribeOn(),和observeOn()方法來指定發生的線程和消費的線程。
subscribeOn():指定subscribe()?所發生的線程,即?Observable.OnSubscribe?被激活時所處的線程。或者叫做事件產生的線程。
observeOn():指定Subscriber?所運行在的線程。或者叫做事件消費的線程。
以及參數Scheduler,RxJava已經為我們提供了一下幾個Scheduler
Schedulers.immediate():直接在當前線程運行,相當于不指定線程。這是默認的?Scheduler。
Schedulers.newThread():總是啟用新線程,并在新線程執行操作。
Schedulers.io(): I/O 操作(讀寫文件、讀寫數據庫、網絡信息交互等)所使用的?Scheduler。行為模式和?newThread()?差不多,區別在于?io()?的內部實現是是用一個無數量上限的線程池,可以重用空閑的線程,因此多數情況下?io()?比?newThread()?更有效率。不要把計算工作放在?io()?中,可以避免創建不必要的線程。
Schedulers.computation():計算所使用的?Scheduler。這個計算指的是 CPU 密集型計算,即不會被 I/O 等操作限制性能的操作,例如圖形的計算。這個?Scheduler?使用的固定的線程池,大小為 CPU 核數。不要把 I/O 操作放在?computation()?中,否則 I/O 操作的等待時間會浪費 CPU。
?AndroidSchedulers.mainThread():它指定的操作將在 Android 主線程運行。
多次切換線程看完上面的介紹想必對RxJava線程的切換有了一些理解,上面只是對事件的發起和消費制定了線程。如果中間有map之類的操作呢?是否可以實現發起的線程在新線程中,map的處理在IO線程,最后的消費在主線程中。
Observable.just("Hello", "Wrold") .subscribeOn(Schedulers.newThread())//指定:在新的線程中發起 .observeOn(Schedulers.io()) //指定:在io線程中處理 .map(new Func1() { @Override public String call(String s) { return handleString(s); //處理數據 } }) .observeOn(AndroidSchedulers.mainThread())//指定:在主線程中處理 .subscribe(new Action1 () { @Override public void call(String s) { show(s); //消費事件 } });
可以看到observeOn()被調用了兩次,分別指定了map的處理的現場和消費事件show(s)的線程。
若將observeOn(AndroidSchedulers.mainThread())去掉會怎么樣?不為消費事件show(s)指定線程后,show(s)會在那里執行?小結
其實,observeOn()?指定的是它之后的操作所在的線程。也就是說,map的處理和最后的消費事件show(s)都會在io線程中執行。
observeOn()可以多次使用,可以隨意變換線程
學會線程控制后才算是真正學會了使用RxJava。RxJava的使用十分靈活,想要對其熟悉使用只有一個辦法,那就是多用啦,熟能生巧。
以上有錯誤之處感謝指出
參考:給 Android 開發者的 RxJava 詳解
(本文部分內容引用自該博客)
文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。
轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/73397.html
摘要:觀察者模式面向的需求是對象觀察者對對象被觀察者的某種變化高度敏感,需要在變化的一瞬間做出反應。規定,當不會再有新的發出時,需要觸發方法作為標志。在事件處理過程中出異常時,會被觸發,同時隊列自動終止,不允許再有事件發出。 我從去年開始使用 RxJava ,到現在一年多了。今年加入了 Flipboard 后,看到 Flipboard 的 Android 項目也在使用 RxJava ,并且使...
閱讀 4002·2023-04-26 02:13
閱讀 2244·2021-11-08 13:13
閱讀 2729·2021-10-11 10:59
閱讀 1732·2021-09-03 00:23
閱讀 1301·2019-08-30 15:53
閱讀 2275·2019-08-28 18:22
閱讀 3050·2019-08-26 10:45
閱讀 727·2019-08-23 17:58