# | Line 5 | Line 5 | |
---|---|---|
5 | */ | |
6 | ||
7 | package java.util.concurrent; | |
8 | + | import java.util.concurrent.locks.*; |
9 | import java.util.*; | |
10 | ||
11 | /** | |
# | Line 17 | Line 18 | public class PriorityBlockingQueue<E> ex | |
18 | implements BlockingQueue<E>, java.io.Serializable { | |
19 | ||
20 | private final PriorityQueue<E> q; | |
20 | – | // private final FairReentrantLock lock = new FairReentrantLock(); |
21 | private final ReentrantLock lock = new ReentrantLock(); | |
22 | private final Condition notEmpty = lock.newCondition(); | |
23 |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |