ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/jsr166/jsr166/src/main/java/util/concurrent/ConcurrentLinkedQueue.java

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

#	Line 785 | Line 785 | public class ConcurrentLinkedQueue<E> ex
785		public Spliterator<E> trySplit() {
786		Node<E> p; int b;
787		final ConcurrentLinkedQueue<E> q = this.queue;
788	<	if (!exhausted &&
789	<	((b = batch) < MAX_QUEUED ||
788	>	if (!exhausted &&
789	>	((b = batch) < MAX_QUEUED ||
790		java.util.concurrent.ForkJoinTask.getQueuedTaskCount() < MAX_QUEUED) &&
791		((p = current) != null || (p = q.first()) != null) &&
792		p.next != null) {
793	<	int n = batch = (b >= MAX_BATCH)? MAX_BATCH : b + 1;
793	>	int n = batch = (b >= MAX_BATCH) ? MAX_BATCH : b + 1;
794		Object[] a;
795		try {
796		a = new Object[n];

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines
>	Changed lines