core pool size should be same with max pool size

treasure-data · Mar 3, 2017 · 981546e · 981546e
1 parent d3950b4
commit 981546e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/digdag-core/src/main/java/io/digdag/core/agent/MultiThreadAgent.java b/digdag-core/src/main/java/io/digdag/core/agent/MultiThreadAgent.java
@@ -53,8 +53,8 @@ public MultiThreadAgent(
         if (config.getMaxThreads() > 0) {
             this.executorQueue = new LinkedBlockingQueue<Runnable>();
             this.executor = new ThreadPoolExecutor(
-                    0, config.getMaxThreads(),
-                    60L, TimeUnit.SECONDS,
+                    config.getMaxThreads(), config.getMaxThreads(),
+                    0L, TimeUnit.SECONDS,
                     executorQueue, threadFactory);
         }
         else {