如何在RXJava中對後臺線程執行長時間計算Android

Question

我想在Android中使用RXJava在後臺線程上執行長時間計算。經過計算，我試圖在Recylerview中呈現結果。我使用下面的代碼段：

Observable.just("true") 
 
       .subscribeOn(Schedulers.io()) 
 
       .map(new Func1<String, String>() { 
 
        @Override 
 
        public String call(String s) { 
 
         feedlist.clear(); 
 
         if (eventFeedItems != null && !eventFeedItems.isEmpty()) { 
 
          for (int i = 0; i < eventFeedItems.size(); i++) { 
 
           if (eventFeedItems != null && eventFeedItems.get(i) != null 
 
             && ((eventFeedItems.get(i).getType() != null && eventFeedItems.get(i).getType().equalsIgnoreCase("EVENT")) 
 
             || (eventFeedItems.get(i).getActivityRequestType() != null && eventFeedItems.get(i).getActivityRequestType().equalsIgnoreCase(EventConstants.TRENDING_ACTIVITY)))) { 
 
            if (eventFeedItems.get(i).getActivityRequestType() != null && !eventFeedItems.get(i).getActivityRequestType().equalsIgnoreCase("")) { 
 
             feedlist.add(new FeedsListModel(eventFeedItems.get(i), eventFeedItems.get(i).getActivityRequestType(), null)); 
 
            } else if (eventFeedItems.get(i).getRequestType() != null && !eventFeedItems.get(i).getRequestType().equalsIgnoreCase("")) { 
 
             feedlist.add(new FeedsListModel(eventFeedItems.get(i), eventFeedItems.get(i).getRequestType(), null)); 
 
            } else 
 
             feedlist.add(new FeedsListModel(eventFeedItems.get(i), EventConstants.ATTENDEE_POST, null)); 
 
           } 
 
          } 
 
         } 
 
         Log.d("calculations","Completed"); 
 
         return ""; 
 
        } 
 
       }) 
 
       .observeOn(AndroidSchedulers.mainThread()) 
 
       .subscribe(new Action1<String>() { 
 
        @Override 
 
        public void call(String s) { 
 
//      feed_list.setLayoutManager(mLayoutManager); 
 
//      feedListAdapter.notifyDataSetChanged(); 
 
         Log.d("Adapter", "Set"); 
 
        } 
 
       }, new Action1<Throwable>() { 
 
        @Override 
 
        public void call(Throwable throwable) { 
 
         Log.d("Exception", "oh! fish..."); 
 
         throwable.printStackTrace(); 
 
        } 
 
       });

利用上述片的我面對UI Hindring碼作爲該ArrayList eventFeedItems尺寸在大約多於300 items.I相信新的RXJava 。請幫助我。

Answer 1

你不會使用map-Operator實現併發。

第一個subscribeOn會將所有想法移動到IO調度程序。沒有併發發生在這裏。

.subscribeOn(Schedulers.io()) 

map-operator將從前一個線程同步調用。在你的情況下，它將來自IO-threadpool的一些線程。

.map(new Func1<String, String>() { 

地圖運營商已執行完畢後，你就會從IO線程到Android的UI事件循環的價值與

.observeOn(AndroidSchedulers.mainThread()) 

值已經從翻譯後移動IO線程到UI線程將處理來自初始可觀察值的下一個值。

Observable.just("true") 

在你的例子中，將不會有更多的值，因爲你只產生一個值。

爲了實現併發性，您應該使用flatMap而不是map。並在flatMap中使用subscribeOn（）在另一個線程上創建每個流。

請考慮這個例子，看看併發是如何發生的。每個可觀察對象都將立即訂閱，時間爲5秒左右。如果現在發生併發，則需要1 + 2 + 3 + 4 + 5秒加上執行時間。

@Test 
public void name1() throws Exception { 

     Observable<Integer> value = Observable.just(1_000, 2_000, 3_000, 4_000, 5_000) 
       .flatMap(i -> Observable.fromCallable(() -> doWork(i)).subscribeOn(Schedulers.io()) 
       ).doOnNext(integer -> System.out.println("value")); 

     value.test().awaitTerminalEvent(); 
} 

private int doWork(int sleepMilli) { 
     try { 
      Thread.sleep(sleepMilli); 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 

     return -1; 
} 

如果您想了解更多關於如何併發與flatMap發生，請考慮閱讀http://tomstechnicalblog.blogspot.de/2015/11/rxjava-achieving-parallelization.html

關於你的代碼，我建議：

• 移動的anonymouse實現的接口來一個私有的內部類實現並使用它的一個實例。您將獲得更易讀的可觀察性

• 不要對其中的運算符的全局變量使用副作用。如果涉及到併發性，你將會得到競爭條件。

  List<FeedsListModel> eventFeedItems = Arrays.asList(new FeedsListModel(), new FeedsListModel()); 
  
  Observable<FeedsListModel> feedsListModelObservable = Observable.fromIterable(eventFeedItems) 
          .flatMap(feedsListModel -> Observable.fromCallable(() -> calculation(feedsListModel)) 
            .subscribeOn(Schedulers.computation()) 
  ); 
  
  feedsListModelObservable 
       .toList() 
       .observeOn(Schedulers.io()) 
       .subscribe(feedsListModels -> { 
        // do UI stuff 
  }); 
  

幫助-方法：

private FeedsListModel calculation(FeedsListModel model) { 
    // do calculation here 

    return new FeedsListModel(); 
}