ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/main/java/util/concurrent/LinkedBlockingDeque.java
(Generate patch)

Comparing jsr166/src/main/java/util/concurrent/LinkedBlockingDeque.java (file contents):
Revision 1.40 by dl, Sat Mar 16 16:03:08 2013 UTC vs.
Revision 1.41 by jsr166, Sun Mar 17 15:34:21 2013 UTC

# 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];

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines