国产成人精品久久免费动漫-国产成人精品天堂-国产成人精品区在线观看-国产成人精品日本-a级毛片无码免费真人-a级毛片毛片免费观看久潮喷

您的位置:首頁技術文章
文章詳情頁

android - 有數據要處理的時候如何使用rxJava進行異步處理數據

瀏覽:74日期:2024-03-01 13:32:19

問題描述

我需要實現下面這段代碼,但是應該是耗時太長放在主界面會卡,所以希望異步處理

JsonReader jsonReader = new JsonReader();cityObject = jsonReader.jsonObject();try { cityArray = cityObject.getJSONArray('city_info'); for (int i=0;i<cityArray.length();i++) {Gson gson = new Gson();JSONObject city = (JSONObject) cityArray.get(i);cityDataList.add(gson.fromJson(city.toString(), CityData.class)); }} catch (JSONException e) { e.printStackTrace();}provinceList = getProvinceList();cityMap = getCityMap();

public class JsonReader { public JSONObject jsonObject(){InputStream inputStream = getClass().getClassLoader().getResourceAsStream('assets/cityList.json');InputStreamReader streamReader = new InputStreamReader(inputStream);BufferedReader reader = new BufferedReader(streamReader);String line;StringBuilder stringBuilder = new StringBuilder();try { while ((line = reader.readLine()) != null) {stringBuilder.append(line); } reader.close(); reader.close(); inputStream.close();} catch (IOException e) { e.printStackTrace();}try { JSONObject cityJson = new JSONObject(stringBuilder.toString()); return cityJson;} catch (JSONException e) { e.printStackTrace();}return null; }}

private List<String> getProvinceList() {List<String> list = new ArrayList<>();for (int i = 0; i < cityDataList.size(); i++) { CityData cityData = cityDataList.get(i); boolean isProvince = false; for (int j = 0; j < list.size(); j++) {if (list.get(j).equals(cityData.getProv())) { isProvince = true; break;} } if (isProvince) continue; else list.add(cityData.getProv());}return list; } private HashMap<String, List<String>> getCityMap() {HashMap<String, List<String>> map = new HashMap<>();for (int i = 0; i < provinceList.size(); i++) { String prov = provinceList.get(i); List<String> list = new ArrayList<>(); for (int j = 0; j < cityDataList.size(); j++) {if (cityDataList.get(j).getProv().equals(prov)) list.add(cityDataList.get(j).getCity()); } map.put(prov, list);}return map; }

這幾個操作循環比較多,比較耗時,我想用rxjava處理,但是對observable的使用還是不太清楚,有人能介紹一下像我這樣observable怎么寫嗎?我想要改進的是用observable通過flatmap等這些操作符來返回provinceList和cityMap,并且把線程轉到后臺,在前臺接收到這兩個數據就好了

問題解答

回答1:

幫樓主寫了下示例代碼,像樓主這種需求,其實無須操作符進行變換的。

Observable.create(new Observable.OnSubscribe<Pair>() { @Override public void call(Subscriber<? super Pair> subscriber) {JsonReader jsonReader = new JsonReader();cityObject = jsonReader.jsonObject();try { cityArray = cityObject.getJSONArray('city_info'); for (int i=0;i<cityArray.length();i++) {Gson gson = new Gson();JSONObject city = (JSONObject) cityArray.get(i);cityDataList.add(gson.fromJson(city.toString(), CityData.class)); }} catch (JSONException e) { e.printStackTrace();}provinceList = getProvinceList();cityMap = getCityMap();Pair pair = new Pair(provinceList, cityMap); }}).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(new Subscriber<Pair>() { @Override public void onCompleted() { } @Override public void onError(Throwable e) { } @Override public void onNext(Pair pair) {//pair.first -> provinceList//pair.second -> cityMap }});回答2:

你需要的是cityDataList這個list吧?那么就可以使用Observable.create來新建一個Observable,把所有操作放在OnSubscribe對象中的call方法中,在最后數據準備完成后調用subscriber相應的onNext就行了。同時處理一下對應的onCompleted和onError

標簽: java
相關文章:
主站蜘蛛池模板: 日本三级韩国三级在线观看a级 | 欧美在线观看成人高清视频 | 天堂1在线观看 | 国产欧美日韩免费一区二区 | 手机在线一区二区三区 | 手机看片日韩日韩国产在线看 | 特级毛片全部免费播放器 | 成人自拍在线 | 久久精品视频在线 | 色狠狠色综合吹潮 | 亚洲不卡一区二区三区在线 | 麻豆日韩| 精品国产不卡一区二区三区 | 欧美一级毛片免费观看视频 | 国产三级小视频在线观看 | 97在线视频免费观看费观看 | 日韩欧美自拍 | 国产精品毛片在线大全 | 欧美巨大video粗暴 | 自拍视频一区 | 亚洲国产成人在人网站天堂 | 无套内谢孕妇毛片免费看 | 国产精品久草 | 免费看成人 | 99久久一区二区精品 | 国产人成午夜免视频网站 | 在线人成精品免费视频 | 精品400部自拍视频在线播放 | 成人免费看www网址入口 | 欧美日韩精品一区二区三区不卡 | 国产精品偷伦费观看 | 波多野结衣视频免费观看 | 亚洲国产成人精品91久久久 | 亚洲综合小视频 | 美女和男人免费网站视频 | 91精品宅男在线观看 | 欧美一级片网站 | 国产91第一页 | 精品国产一区二区三区www | 久热久操| 欧美成人精品高清在线观看 |