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