ViewVC Help

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

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

Comparing jsr166/src/main/java/util/concurrent/PriorityBlockingQueue.java (file contents):
Revision 1.90 by jsr166, Mon Jan 28 21:59:11 2013 UTC vs.
Revision 1.91 by dl, Fri Feb 1 01:02:37 2013 UTC

#	Line 20 | Line 20 | import java.util.SortedSet;
20		import java.util.Spliterator;
21		import java.util.stream.Stream;
22		import java.util.stream.Streams;
23	<	import java.util.function.Block;
23	>	import java.util.function.Consumer;
24
25		/**
26		* An unbounded {@linkplain BlockingQueue blocking queue} that uses
#	Line 952 | Line 952 | public class PriorityBlockingQueue<E> ex
952		new PBQSpliterator<E>(array, lo, index = mid);
953		}
954
955	<	public void forEach(Block<? super E> block) {
955	>	public void forEach(Consumer<? super E> block) {
956		Object[] a; int i, hi; // hoist accesses and checks from loop
957		if (block == null)
958		throw new NullPointerException();
#	Line 966 | Line 966 | public class PriorityBlockingQueue<E> ex
966		}
967		}
968
969	<	public boolean tryAdvance(Block<? super E> block) {
969	>	public boolean tryAdvance(Consumer<? super E> block) {
970		if (index >= 0 && index < fence) {
971		@SuppressWarnings("unchecked") E e = (E) array[index++];
972		block.accept(e);

Diff Legend

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