# | Line 18 | Line 18 | public class PriorityBlockingQueue<E> ex | |
---|---|---|
18 | implements BlockingQueue<E>, java.io.Serializable { | |
19 | ||
20 | private final PriorityQueue<E> q; | |
21 | < | private final ReentrantLock lock = new ReentrantLock(); |
21 | > | private final ReentrantLock lock = new ReentrantLock(true); |
22 | private final Condition notEmpty = lock.newCondition(); | |
23 | ||
24 | /** |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |