Android: Rxjava2多线程导致的OOM

         当下游观察者使用Schedulers.io()，并且中执行的异步任务过多（比如往100份文件中写入），因为IO scheduler是一个无上限线程池，如果短时间并发量过大，上述情况就是开了100个线程里去执行操作，在手机端大概率可能出现OOM。

1. 声明线程池：

1.  
   private ExecutorService executor;
2.  
    
3.  
   executor = Executors.newFixedThreadPool(2);

2. 下游观察者使用线程池：

1.  
   private Observable<Integer> checkPathAndMakeTask(File jsonFile) {
2.  
   return Observable.create(emitter ->
3.  
   mRidingLogRepository.getCountByRidinglogPath(jsonFile.getAbsolutePath())
4.  
   .subscribeOn(Schedulers.io())
5.  
   .observeOn(Schedulers.from(executor)) //重点行
6.  
   .subscribe(new SingleObserver<Integer>() {
7.  
   @Override
8.  
   public void onSubscribe(@NonNull Disposable d) {
9.  
    
10.  
    }
11.  
     
12.  
    @Override
13.  
    public void onSuccess(@NonNull Integer integer) {
14.  
    if (integer == 0) {
15.  
    singleTransformTask(jsonFile, emitter);
16.  
    } else {
17.  
    emitter.onComplete();
18.  
    }
19.  
    }
20.  
     
21.  
    @Override
22.  
    public void onError(@NonNull Throwable e) {
23.  
    emitter.onComplete();
24.  
    }
25.  
    }));
26.  
    }

3.  使用完毕后释放关闭线程池

1.  
   // all task obserables
2.  
   Observable.mergeArray(list.toArray(new Observable[0])).subscribe(new Observer<Object>() {
3.  
   @Override
4.  
   public void onSubscribe(@NonNull Disposable d) {
5.  
   Log.v(TAG, "onSubscribe");
6.  
   }
7.  
    
8.  
   @Override
9.  
   public void onNext(@NonNull Object o) {
10.  
     
11.  
    }
12.  
     
13.  
    @Override
14.  
    public void onError(@NonNull Throwable e) {
15.  
    Log.v(TAG, e.getMessage());
16.  
    isDataMigration.postValue(false);
17.  
    }
18.  
     
19.  
    @Override
20.  
    public void onComplete() {
21.  
    isDataMigration.postValue(false);
22.  
    sharedPreferences.edit().putBoolean(SharedPreferenceStore.KEY_OLD_DDCD_DATA_CONVERTED, true).apply();
23.  
    ridingLogStore.getAllLogAndJudge();
24.  
    //使用完毕后释放
25.  
    if (executor != null) {
26.  
    executor.shutdownNow();
27.  
    executor = null;
28.  
    }
29.  
    }
30.  
    });
31.  
    }

这篇好文章是转载于：学新通技术网