av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

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

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

瀏覽:75日期: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
相關文章:
主站蜘蛛池模板: 久久久久一区二区三区 | 中文字幕av一区二区三区 | 国产日韩一区二区 | 理论片午午伦夜理片影院 | 午夜精品一区二区三区免费视频 | 久久久一区二区 | 国产精品免费一区二区三区四区 | 中文字幕 在线观看 | 亚洲精品女优 | 欧美激情免费在线 | 成人av网站在线观看 | 中文字幕综合 | 成人三级视频 | 国产亚洲成av人在线观看导航 | 国产高清免费视频 | 精品欧美久久 | 欧美一级黄带 | 毛片一区二区三区 | 欧美乱操 | 黄色一级毛片免费看 | 欧美成人激情 | 国产欧美一区二区三区日本久久久 | 日韩欧美视频在线 | 久久久成人免费一区二区 | 久久国产精品视频 | av片免费观看 | 一二三区在线 | 国产成人叼嘿视频在线观看 | 伊人久久成人 | 亚洲欧美一区二区三区在线 | 亚洲欧美在线观看视频 | 成人av一区二区亚洲精 | 欧美精品久久 | 亚洲精品一区在线观看 | 亚洲电影第三页 | 男人天堂网址 | 五月花丁香婷婷 | 黄色毛片免费 | 蜜桃特黄a∨片免费观看 | 美女黄色在线观看 | 国产免费一区 |