線程切換

• 基礎(chǔ)概念

  在不指定線程的情況下， RxJava 遵循的是線程不變的原則，即：在哪個(gè)線程調(diào)用 subscribe()，Observable和Observer就在哪個(gè)線程荤牍，默認(rèn)情況下Observable和Observer在同一個(gè)線程工作。如果需要切換線程榄融，就需要用到 Scheduler （調(diào)度器）参淫。

• 應(yīng)用場景

  網(wǎng)絡(luò)請求、數(shù)據(jù)庫操作愧杯、遍歷大列表等等

• 基礎(chǔ)元素

  Observable.subscribeOn(Scheduler scheduler) //指定Observable發(fā)送事件的線程
  Observable.observeOn(Scheduler scheduler) //指定Observer接收事件的線程
  
  Scheduler //線程控制器，rxjava指定了以下幾個(gè)常用的線程
  Schedulers.io() //io操作的線程, 通常用于網(wǎng)絡(luò),讀寫文件等io密集型的操作
  Schedulers.computation() //CPU計(jì)算密集型的操作線程, 例如需要大量計(jì)算的操作
  Schedulers.newThread() //常規(guī)的新線程
  Schedulers.newThread() //Android的主線程
  

• 代碼實(shí)現(xiàn)

   //TODO 創(chuàng)建觀察者
   Observer observer = ......;
   //TODO 創(chuàng)建被觀察者
   Observable observable = .......;
   //TODO 注冊和線程切換
   observable.subscribeOn(Schedulers.io()) //指定被觀察者發(fā)送事件的使用io線程
   .observeOn(AndroidSchedulers.mainThread()) //指定觀察者接收事件使用主線程
   .subscribe(mObserver);
  

• 特殊說明

  多次調(diào)用subscribeOn()鞋既，只有第一次有效力九；多次調(diào)用observeOn()耍铜，每次都有效。

• 實(shí)踐案例

  在io線程里計(jì)算一個(gè)集合所有數(shù)字的和

     //生成測試數(shù)據(jù)
     ArrayList<Integer> datas = new ArrayList<>();
     for (int i = 0; i < 100000; i++) {
         datas.add(i);
     }
  
     Observable<Integer> observable = Observable.create(new Observable.OnSubscribe<Integer>() {
         @Override
         public void call(Subscriber<? super Integer> subscriber) {
             Log.d(TAG, "被觀察者線程: " + Thread.currentThread().getName());
             int sum =0;
             for (Integer data : datas) {
                 sum+=data;
             }
             subscriber.onNext(sum);
         }
     });
  
     observable
             .subscribeOn(Schedulers.io())
             .observeOn(AndroidSchedulers.mainThread())
             .subscribe(new Observer<Integer>() {
                 @Override
                 public void onCompleted() {
  
                 }
  
                 @Override
                 public void onError(Throwable e) {
  
                 }
  
                 @Override
                 public void onNext(Integer integer) {
                     Log.d(TAG, "觀察者線程: " + Thread.currentThread().getName());
                     Log.d(TAG, "計(jì)算完畢" +integer);
                 }
             });
  

}

?