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

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

# Line 929 | Line 929 | public class LinkedTransferQueue<E> exte
929          public Spliterator<E> trySplit() {
930              Node p; int b;
931              final LinkedTransferQueue<E> q = this.queue;
932 <            if (!exhausted &&
933 <                ((b = batch) < MAX_QUEUED ||
932 >            if (!exhausted &&
933 >                ((b = batch) < MAX_QUEUED ||
934                   java.util.concurrent.ForkJoinTask.getQueuedTaskCount() < MAX_QUEUED) &&
935                  ((p = current) != null || (p = q.firstDataNode()) != null) &&
936                  p.next != null) {
937 <                int n = batch = (b >= MAX_BATCH)? MAX_BATCH : b + 1;
937 >                int n = batch = (b >= MAX_BATCH) ? MAX_BATCH : b + 1;
938                  Object[] a;
939                  try {
940                      a = new Object[n];

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines