# | Line 1150 | Line 1150 | public class LinkedBlockingDeque<E> | |
---|---|---|
1150 | final ReentrantLock lock = q.lock; | |
1151 | if (!exhausted && | |
1152 | ((b = batch) < MAX_QUEUED || | |
1153 | < | java.util.concurrent.ForkJoinTask.getQueuedTaskCount() < MAX_QUEUED)) { |
1153 | > | ForkJoinTask.getQueuedTaskCount() < MAX_QUEUED)) { |
1154 | int n = batch = (b >= MAX_BATCH) ? MAX_BATCH : b + 1; | |
1155 | Object[] a; | |
1156 | try { |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |