Merge branch 'feature/issue_343_executor_thread_pool_size'

# Conflicts:
#	src/main/java/com/couchbase/lite/Manager.java

Author: Hideki Itakura

src/main/java/com/couchbase/lite/Manager.java

@@ -689,5 +689,13 @@ protected boolean isAutoMigrateBlobStoreFilename() {
     private static boolean isWindows() {
         return (OS.indexOf("win") >= 0);
     }
+
+    /**
+     * @exclude
+     */
+    @InterfaceAudience.Private
+    public int getExecutorThreadPoolSize() {
+        return this.options.getExecutorThreadPoolSize();
+    }
 }
 

src/main/java/com/couchbase/lite/ManagerOptions.java

@@ -6,15 +6,22 @@
 public class ManagerOptions {
 
     /**
-     *  No modifications to databases are allowed.
+     * No modifications to databases are allowed.
      */
     private boolean readOnly = false;
 
     /**
-     *  automatically migrate blobstore filename
+     * automatically migrate blobstore filename
      */
     private boolean autoMigrateBlobStoreFilename = false;
 
+    /**
+     * the number of threads to keep in the pool for RemoteRequestExecutor
+     * ReplicationInternal.java: public static final int EXECUTOR_THREAD_POOL_SIZE = 5;
+     * https://github.com/couchbase/couchbase-lite-java-core/issues/343
+     */
+    private int executorThreadPoolSize = 0;
+
     public ManagerOptions() {
     }
 
@@ -33,4 +40,12 @@ public boolean isAutoMigrateBlobStoreFilename() {
     public void setAutoMigrateBlobStoreFilename(boolean autoMigrateBlobStoreFilename) {
         this.autoMigrateBlobStoreFilename = autoMigrateBlobStoreFilename;
     }
-}
+
+    public int getExecutorThreadPoolSize() {
+        return executorThreadPoolSize;
+    }
+
+    public void setExecutorThreadPoolSize(int executorThreadPoolSize) {
+        this.executorThreadPoolSize = executorThreadPoolSize;
+    }
+}

src/main/java/com/couchbase/lite/replicator/ReplicationInternal.java

@@ -320,7 +320,10 @@ protected void initNetworkReachabilityManager() {
 
     protected void goOnlineInitialStartup() {
 
-        remoteRequestExecutor = Executors.newScheduledThreadPool(EXECUTOR_THREAD_POOL_SIZE, new ThreadFactory() {
+        int executorThreadPoolSize = db.getManager().getExecutorThreadPoolSize() <= 0 ?
+                EXECUTOR_THREAD_POOL_SIZE: db.getManager().getExecutorThreadPoolSize();
+        Log.v(Log.TAG_SYNC, "executorThreadPoolSize=" +  executorThreadPoolSize);
+        remoteRequestExecutor = Executors.newScheduledThreadPool(executorThreadPoolSize, new ThreadFactory() {
             private int counter = 0;
             @Override
             public Thread newThread(Runnable r) {