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.136 by jsr166, Sun May 6 22:40:35 2018 UTC vs.
Revision 1.137 by jsr166, Sun May 6 22:53:18 2018 UTC

#	Line 851 | Line 851 | public class PriorityBlockingQueue<E> ex
851		removeEq(array[lastRet]);
852		lastRet = -1;
853		}
854	+
855	+	public void forEachRemaining(Consumer<? super E> action) {
856	+	Objects.requireNonNull(action);
857	+	final Object[] es = array;
858	+	int i;
859	+	if ((i = cursor) < es.length) {
860	+	lastRet = -1;
861	+	cursor = es.length;
862	+	for (; i < es.length; i++)
863	+	action.accept((E) es[i]);
864	+	lastRet = es.length - 1;
865	+	}
866	+	}
867		}
868
869		/**

Diff Legend

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