android - rxjava多線程并發怎么控制順序
問題描述
需求是從服務器獲取聊天列表,然后遍歷獲取聊天記錄,我這里用了Observable.from(conversations)然后對conversation插入本地數據庫,并且過濾得到需要的數據,最后更新view我看了一下午,這么多關鍵詞相關SerializedSubject(我用SerializedSubject.from(conversations)也不行,而轉類型Observable也報錯)trampoline(把任務放到當前線程的隊列中,等當前任務執行完了,再繼續執行隊列中的任務)concatEager(這個操作符跟concatMap有什么區別http://blog.csdn.net/kisty_ya... 但是使用上沒例子不太懂)剛開始是onNext里面處理下一步驟,然后我就用flatMap處理了,但是還是發射完成就結束了,沒有等onNext執行完,而且感覺doOnNext和flatMap是一樣的,希望能夠指點迷津,感覺像無頭蒼蠅一樣,能不能用偽代碼寫一下思路謝謝
問題解答
回答1:過濾的話應該用Filter這個操作符吧
回答2:用這個操作符concatMap可以保證線程執行的順序不會錯亂!
回答3:Obserable.fromCallable() .filter() .subscribe(io) .obserableOn(ui) .subscribe(action) 如果是需要將過濾的數據重新保存 Obserable data = Obserable.fromCallable() .filter() .subscribe(io) .share(); data.obserableon(io) .subscribe(數據庫) data.obserableOn(ui) .subscribe(更新)
相關文章:
1. javascript - sublime快鍵鍵問題2. javascript - immutable配合react提升性能?3. css - 寫頁面遇到個布局問題,求大佬們幫解答,在線等,急!~4. javascript - nodejs關于進程間發送句柄的一點疑問5. Apache 已經把網站根目錄的改為allow from all了,但是服務器還是不能訪問?6. 實現bing搜索工具urlAPI提交7. 配置Apache時,添加對PHP的支持時語法錯誤8. vue.js - Vue 如何像Angular.js watch 一樣監聽數據變化9. javascript - 移動端上不能實現拖拽布局嗎?10. phpstudy8.1支持win11系統嗎?

網公網安備