# | Line 27 | Line 27 | public class DelayQueue<E extends Delaye | |
---|---|---|
27 | implements BlockingQueue<E> { | |
28 | ||
29 | private transient final ReentrantLock lock = new ReentrantLock(); | |
30 | < | private transient final ReentrantLock.ConditionObject available = lock.newCondition(); |
30 | > | private transient final Condition available = lock.newCondition(); |
31 | private final PriorityQueue<E> q = new PriorityQueue<E>(); | |
32 | ||
33 | /** |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |