.../java/org/apache/hadoop/hbase/util/StealJobQueue.java | 16 +--------------- 1 file changed, 1 insertion(+), 15 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/StealJobQueue.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/StealJobQueue.java index 9a5d595..efd3da3 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/StealJobQueue.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/StealJobQueue.java @@ -50,21 +50,7 @@ public class StealJobQueue extends PriorityBlockingQueue { private final transient Condition notEmpty = lock.newCondition(); public StealJobQueue(Comparator comparator) { - this.stealFromQueue = new PriorityBlockingQueue(11, comparator) { - - private static final long serialVersionUID = -7070010365201826904L; - - @Override - public boolean offer(T t) { - lock.lock(); - try { - notEmpty.signal(); - return super.offer(t); - } finally { - lock.unlock(); - } - } - }; + this(11, 11, comparator); } public StealJobQueue(int initCapacity, int stealFromQueueInitCapacity,