Also allow PrepWorkManager to queue tasks

Multifarious · Jul 22, 2013 · 472f13a · 472f13a
1 parent f0d6eb3
commit 472f13a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/skid-road/src/main/java/io/ifar/skidroad/prepping/PrepWorkerManager.java b/skid-road/src/main/java/io/ifar/skidroad/prepping/PrepWorkerManager.java
@@ -174,7 +174,7 @@ public void start() {
         LOG.info("Starting {}.", PrepWorkerManager.class.getSimpleName());
         this.executor = new ThreadPoolExecutor(0, maxConcurrentPrepWork,
                 60L, TimeUnit.SECONDS,
-                new SynchronousQueue<Runnable>());
+                new LinkedBlockingQueue<Runnable>());
         tracker.addListener(this);
         Map<String,Object> retryConfiguration = new HashMap<>(1);
         retryConfiguration.put(RetryJob.PREP_WORKER_MANAGER, this);