tweak thread pool startup log msgs

codeforkjeff · Mar 5, 2017 · 598d31c · 598d31c
1 parent bc3915f
commit 598d31c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/java/com/codefork/refine/ThreadPool.java b/src/main/java/com/codefork/refine/ThreadPool.java
@@ -41,9 +41,11 @@ public ThreadPool(long waitPeriodBeforeShrinkingMs,
 
     public void start() {
         // TODO: make thread pool size configurable
-        log.info("Starting thread pool, size = " + INITIAL_POOL_SIZE);
         if(executor == null || executor.isShutdown()) {
+            log.info("Starting thread pool, size = " + INITIAL_POOL_SIZE);
             executor = new ThreadPoolExecutor(INITIAL_POOL_SIZE, INITIAL_POOL_SIZE, 0, TimeUnit.HOURS, new LinkedBlockingQueue<Runnable>());
+        } else {
+            log.info("Thread pool already started, doing nothing.");
         }
     }