ViewVC Help

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

root/jsr166/jsr166/src/test/tck/BlockingQueueTest.java

Comparing jsr166/src/test/tck/BlockingQueueTest.java (file contents):
Revision 1.20 by jsr166, Sun May 14 14:52:50 2017 UTC vs.
Revision 1.21 by jsr166, Wed Jan 10 14:41:52 2018 UTC

#	Line 189 | Line 189 | public abstract class BlockingQueueTest
189		public void testDrainToNonPositiveMaxElements() {
190		final BlockingQueue q = emptyCollection();
191		final int[] ns = { 0, -1, -42, Integer.MIN_VALUE };
192	<	for (int n : ns)
193	<	assertEquals(0, q.drainTo(new ArrayList(), n));
192	>	final ArrayList sink = new ArrayList();
193	>	for (int n : ns) {
194	>	assertEquals(0, q.drainTo(sink, n));
195	>	assertTrue(sink.isEmpty());
196	>	}
197		if (q.remainingCapacity() > 0) {
198		// Not SynchronousQueue, that is
199		Object one = makeElement(1);
200		q.add(one);
198	–	ArrayList c = new ArrayList();
201		for (int n : ns)
202	<	assertEquals(0, q.drainTo(new ArrayList(), n));
202	>	assertEquals(0, q.drainTo(sink, n));
203		assertEquals(1, q.size());
204		assertSame(one, q.poll());
205	<	assertTrue(c.isEmpty());
205	>	assertTrue(sink.isEmpty());
206		}
207		}
208

Diff Legend

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