increase the corePoolSize and MaxPoolSize of AsyncTaskExecutor

Author: krishna

fileloader/src/main/java/com/krishna/fileloader/FileLoader.java

@@ -79,7 +79,7 @@ public static MultiFileDownloader multiFileDownload(Context context) {
 
     public FileResponse loadFile() throws Exception {
         validateAllParameters();
-        DownloadResponse response = getFileLoaderAsyncTask().execute().get();
+        DownloadResponse response = getFileLoaderAsyncTask().executeOnExecutor(Utils.getThreadPoolExecutor()).get();
         if (response.getDownloadedFile() != null) {
             return createFileResponse(response.getDownloadedFile());
         } else {
@@ -102,7 +102,7 @@ public void loadFileAsync() {
             synchronized (REQUEST_QUEUE_LOCK) {
                 fileLoadRequestSet.add(fileLoadRequest);
             }
-            getFileLoaderAsyncTask().executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR);
+            getFileLoaderAsyncTask().executeOnExecutor(Utils.getThreadPoolExecutor());
         }
     }
 

fileloader/src/main/java/com/krishna/fileloader/utility/Utils.java

@@ -6,6 +6,10 @@
 import java.io.FileInputStream;
 import java.io.IOException;
 import java.io.ObjectInputStream;
+import java.util.concurrent.BlockingQueue;
+import java.util.concurrent.LinkedBlockingQueue;
+import java.util.concurrent.ThreadPoolExecutor;
+import java.util.concurrent.TimeUnit;
 
 /**
  * Created by krishna on 15/10/17.
@@ -35,4 +39,12 @@ private static Object deserializeObject(File file, Class clazz) throws IOExcepti
         in.close();
         return object;
     }
+
+    public static ThreadPoolExecutor getThreadPoolExecutor() {
+        int mCorePoolSize = 60;
+        int mMaximumPoolSize = 80;
+        int mKeepAliveTime = 30;
+        BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<Runnable>(mMaximumPoolSize);
+        return new ThreadPoolExecutor(mCorePoolSize, mMaximumPoolSize, mKeepAliveTime, TimeUnit.SECONDS, workQueue);
+    }
 }