Set default executorService for OkHttp

arms/src/main/java/com/jess/arms/di/module/ClientModule.java

@@ -18,27 +18,25 @@ package com.jess.arms.di.module;
 import android.app.Application;
 import android.content.Context;
 import android.support.annotation.Nullable;
-
 import com.google.gson.Gson;
 import com.jess.arms.http.GlobalHttpHandler;
 import com.jess.arms.http.log.RequestInterceptor;
 import com.jess.arms.utils.DataHelper;
-
+import dagger.Binds;
+import dagger.Module;
+import dagger.Provides;
+import io.rx_cache2.internal.RxCache;
+import io.victoralbertos.jolyglot.GsonSpeaker;
 import java.io.File;
 import java.io.IOException;
 import java.util.List;
+import java.util.concurrent.ExecutorService;
 import java.util.concurrent.TimeUnit;
-
 import javax.inject.Named;
 import javax.inject.Singleton;
-
-import dagger.Binds;
-import dagger.Module;
-import dagger.Provides;
-import io.rx_cache2.internal.RxCache;
-import io.victoralbertos.jolyglot.GsonSpeaker;
 import me.jessyan.rxerrorhandler.core.RxErrorHandler;
 import me.jessyan.rxerrorhandler.handler.listener.ResponseErrorListener;
+import okhttp3.Dispatcher;
 import okhttp3.HttpUrl;
 import okhttp3.Interceptor;
 import okhttp3.OkHttpClient;
@@ -102,7 +100,7 @@ public abstract class ClientModule {
     @Singleton
     @Provides
     static OkHttpClient provideClient(Application application, @Nullable OkhttpConfiguration configuration, OkHttpClient.Builder builder, Interceptor intercept
-            , @Nullable List<Interceptor> interceptors, @Nullable GlobalHttpHandler handler) {
+            , @Nullable List<Interceptor> interceptors, @Nullable GlobalHttpHandler handler, ExecutorService executorService) {
         builder
                 .connectTimeout(TIME_OUT, TimeUnit.SECONDS)
                 .readTimeout(TIME_OUT, TimeUnit.SECONDS)
@@ -122,6 +120,9 @@ public abstract class ClientModule {
             }
         }
 
+        // 为 OkHttp 设置默认的线程池。
+        builder.dispatcher(new Dispatcher(executorService));
+
         if (configuration != null)
             configuration.configOkhttp(application, builder);
         return builder.build();