From dbaaa6af9299f8e7cf59b0d24398304324dfd198 Mon Sep 17 00:00:00 2001 From: Charles Allen Date: Tue, 1 Dec 2015 19:13:07 -0800 Subject: [PATCH] Make the TaskQueue big lock fair --- .../src/main/java/io/druid/indexing/overlord/TaskQueue.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/indexing-service/src/main/java/io/druid/indexing/overlord/TaskQueue.java b/indexing-service/src/main/java/io/druid/indexing/overlord/TaskQueue.java index 594c46d5716..df6f27d81ba 100644 --- a/indexing-service/src/main/java/io/druid/indexing/overlord/TaskQueue.java +++ b/indexing-service/src/main/java/io/druid/indexing/overlord/TaskQueue.java @@ -76,7 +76,7 @@ public class TaskQueue private final TaskLockbox taskLockbox; private final ServiceEmitter emitter; - private final ReentrantLock giant = new ReentrantLock(); + private final ReentrantLock giant = new ReentrantLock(true); private final Condition managementMayBeNecessary = giant.newCondition(); private final ExecutorService managerExec = Executors.newSingleThreadExecutor( new ThreadFactoryBuilder()