ViewVC Help

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

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

Comparing jsr166/src/main/java/util/concurrent/SynchronousQueue.java (file contents):
Revision 1.92 by jsr166, Tue Feb 5 19:54:06 2013 UTC vs.
Revision 1.93 by dl, Sun Feb 17 23:36:34 2013 UTC

#	Line 9 | Line 9 | package java.util.concurrent;
9		import java.util.concurrent.locks.LockSupport;
10		import java.util.concurrent.locks.ReentrantLock;
11		import java.util.*;
12	+	import java.util.Spliterator;
13	+	import java.util.stream.Stream;
14	+	import java.util.stream.Streams;
15	+	import java.util.function.Consumer;
16
17		/**
18		* A {@linkplain BlockingQueue blocking queue} in which each insert
#	Line 1048 | Line 1052 | public class SynchronousQueue<E> extends
1052		public void remove() { throw new IllegalStateException(); }
1053		}
1054
1055	+	Spliterator<E> spliterator() {
1056	+	return Streams.emptySpliterator();
1057	+	}
1058	+
1059	+	public Stream<E> stream() {
1060	+	return Streams.stream(spliterator());
1061	+	}
1062	+
1063	+	public Stream<E> parallelStream() {
1064	+	return Streams.parallelStream(spliterator());
1065	+	}
1066	+
1067		/**
1068		* Returns a zero-length array.
1069		* @return a zero-length array

Diff Legend

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