ViewVC Help

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

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

Comparing jsr166/src/test/tck/ArrayBlockingQueueTest.java (file contents):
Revision 1.45 by dl, Fri May 6 11:22:07 2011 UTC vs.
Revision 1.53 by jsr166, Tue Feb 21 01:54:03 2012 UTC

#	Line 6 | Line 6
6		* Pat Fisher, Mike Judd.
7		*/
8
9	–
9		import junit.framework.*;
10	<	import java.util.*;
11	<	import java.util.concurrent.*;
10	>	import java.util.Arrays;
11	>	import java.util.ArrayList;
12	>	import java.util.Collection;
13	>	import java.util.Iterator;
14	>	import java.util.NoSuchElementException;
15	>	import java.util.Queue;
16	>	import java.util.concurrent.ArrayBlockingQueue;
17	>	import java.util.concurrent.BlockingQueue;
18	>	import java.util.concurrent.CountDownLatch;
19	>	import java.util.concurrent.Executors;
20	>	import java.util.concurrent.ExecutorService;
21		import static java.util.concurrent.TimeUnit.MILLISECONDS;
14	–	import java.io.*;
22
23		public class ArrayBlockingQueueTest extends JSR166TestCase {
24
25		public static class Fair extends BlockingQueueTest {
26		protected BlockingQueue emptyCollection() {
27	<	return new ArrayBlockingQueue(20, true);
27	>	return new ArrayBlockingQueue(SIZE, true);
28		}
29		}
30
31		public static class NonFair extends BlockingQueueTest {
32		protected BlockingQueue emptyCollection() {
33	<	return new ArrayBlockingQueue(20, false);
33	>	return new ArrayBlockingQueue(SIZE, false);
34		}
35		}
36
#	Line 38 | Line 45 | public class ArrayBlockingQueueTest exte
45		}
46
47		/**
48	<	* Create a queue of given size containing consecutive
48	>	* Creates a queue of given size containing consecutive
49		* Integers 0 ... n.
50		*/
51		private ArrayBlockingQueue<Integer> populatedQueue(int n) {
#	Line 64 | Line 71 | public class ArrayBlockingQueueTest exte
71		*/
72		public void testConstructor2() {
73		try {
74	<	ArrayBlockingQueue q = new ArrayBlockingQueue(0);
74	>	new ArrayBlockingQueue(0);
75		shouldThrow();
76		} catch (IllegalArgumentException success) {}
77		}
#	Line 74 | Line 81 | public class ArrayBlockingQueueTest exte
81		*/
82		public void testConstructor3() {
83		try {
84	<	ArrayBlockingQueue q = new ArrayBlockingQueue(1, true, null);
84	>	new ArrayBlockingQueue(1, true, null);
85		shouldThrow();
86		} catch (NullPointerException success) {}
87		}
#	Line 83 | Line 90 | public class ArrayBlockingQueueTest exte
90		* Initializing from Collection of null elements throws NPE
91		*/
92		public void testConstructor4() {
93	+	Collection<Integer> elements = Arrays.asList(new Integer[SIZE]);
94		try {
95	<	Integer[] ints = new Integer[SIZE];
88	<	ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE, false, Arrays.asList(ints));
95	>	new ArrayBlockingQueue(SIZE, false, elements);
96		shouldThrow();
97		} catch (NullPointerException success) {}
98		}
#	Line 94 | Line 101 | public class ArrayBlockingQueueTest exte
101		* Initializing from Collection with some null elements throws NPE
102		*/
103		public void testConstructor5() {
104	+	Integer[] ints = new Integer[SIZE];
105	+	for (int i = 0; i < SIZE-1; ++i)
106	+	ints[i] = i;
107	+	Collection<Integer> elements = Arrays.asList(ints);
108		try {
109	<	Integer[] ints = new Integer[SIZE];
99	<	for (int i = 0; i < SIZE-1; ++i)
100	<	ints[i] = new Integer(i);
101	<	ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE, false, Arrays.asList(ints));
109	>	new ArrayBlockingQueue(SIZE, false, Arrays.asList(ints));
110		shouldThrow();
111		} catch (NullPointerException success) {}
112		}
#	Line 107 | Line 115 | public class ArrayBlockingQueueTest exte
115		* Initializing from too large collection throws IAE
116		*/
117		public void testConstructor6() {
118	+	Integer[] ints = new Integer[SIZE];
119	+	for (int i = 0; i < SIZE; ++i)
120	+	ints[i] = i;
121	+	Collection<Integer> elements = Arrays.asList(ints);
122		try {
123	<	Integer[] ints = new Integer[SIZE];
112	<	for (int i = 0; i < SIZE; ++i)
113	<	ints[i] = new Integer(i);
114	<	ArrayBlockingQueue q = new ArrayBlockingQueue(1, false, Arrays.asList(ints));
123	>	new ArrayBlockingQueue(SIZE - 1, false, elements);
124		shouldThrow();
125		} catch (IllegalArgumentException success) {}
126		}
#	Line 122 | Line 131 | public class ArrayBlockingQueueTest exte
131		public void testConstructor7() {
132		Integer[] ints = new Integer[SIZE];
133		for (int i = 0; i < SIZE; ++i)
134	<	ints[i] = new Integer(i);
135	<	ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE, true, Arrays.asList(ints));
134	>	ints[i] = i;
135	>	Collection<Integer> elements = Arrays.asList(ints);
136	>	ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE, true, elements);
137		for (int i = 0; i < SIZE; ++i)
138		assertEquals(ints[i], q.poll());
139		}
#	Line 161 | Line 171 | public class ArrayBlockingQueueTest exte
171		}
172
173		/**
164	–	* offer(null) throws NPE
165	–	*/
166	–	public void testOfferNull() {
167	–	try {
168	–	ArrayBlockingQueue q = new ArrayBlockingQueue(1);
169	–	q.offer(null);
170	–	shouldThrow();
171	–	} catch (NullPointerException success) {}
172	–	}
173	–
174	–	/**
175	–	* add(null) throws NPE
176	–	*/
177	–	public void testAddNull() {
178	–	try {
179	–	ArrayBlockingQueue q = new ArrayBlockingQueue(1);
180	–	q.add(null);
181	–	shouldThrow();
182	–	} catch (NullPointerException success) {}
183	–	}
184	–
185	–	/**
174		* Offer succeeds if not full; fails if full
175		*/
176		public void testOffer() {
#	Line 207 | Line 195 | public class ArrayBlockingQueueTest exte
195		}
196
197		/**
210	–	* addAll(null) throws NPE
211	–	*/
212	–	public void testAddAll1() {
213	–	try {
214	–	ArrayBlockingQueue q = new ArrayBlockingQueue(1);
215	–	q.addAll(null);
216	–	shouldThrow();
217	–	} catch (NullPointerException success) {}
218	–	}
219	–
220	–	/**
198		* addAll(this) throws IAE
199		*/
200		public void testAddAllSelf() {
#	Line 228 | Line 205 | public class ArrayBlockingQueueTest exte
205		} catch (IllegalArgumentException success) {}
206		}
207
231	–
232	–	/**
233	–	* addAll of a collection with null elements throws NPE
234	–	*/
235	–	public void testAddAll2() {
236	–	try {
237	–	ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE);
238	–	Integer[] ints = new Integer[SIZE];
239	–	q.addAll(Arrays.asList(ints));
240	–	shouldThrow();
241	–	} catch (NullPointerException success) {}
242	–	}
243	–
208		/**
209		* addAll of a collection with any null elements throws NPE after
210		* possibly adding some elements
#	Line 286 | Line 250 | public class ArrayBlockingQueueTest exte
250		}
251
252		/**
289	–	* put(null) throws NPE
290	–	*/
291	–	public void testPutNull() throws InterruptedException {
292	–	try {
293	–	ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE);
294	–	q.put(null);
295	–	shouldThrow();
296	–	} catch (NullPointerException success) {}
297	–	}
298	–
299	–	/**
253		* all elements successfully put are contained
254		*/
255		public void testPut() throws InterruptedException {
#	Line 314 | Line 267 | public class ArrayBlockingQueueTest exte
267		*/
268		public void testBlockingPut() throws InterruptedException {
269		final ArrayBlockingQueue q = new ArrayBlockingQueue(SIZE);
270	<	Thread t = new Thread(new CheckedRunnable() {
270	>	final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
271	>	Thread t = newStartedThread(new CheckedRunnable() {
272		public void realRun() throws InterruptedException {
273		for (int i = 0; i < SIZE; ++i)
274		q.put(i);
275		assertEquals(SIZE, q.size());
276		assertEquals(0, q.remainingCapacity());
277	+
278	+	Thread.currentThread().interrupt();
279		try {
280		q.put(99);
281		shouldThrow();
282		} catch (InterruptedException success) {}
283	+	assertFalse(Thread.interrupted());
284	+
285	+	pleaseInterrupt.countDown();
286	+	try {
287	+	q.put(99);
288	+	shouldThrow();
289	+	} catch (InterruptedException success) {}
290	+	assertFalse(Thread.interrupted());
291		}});
292
293	<	t.start();
294	<	delay(SHORT_DELAY_MS);
293	>	await(pleaseInterrupt);
294	>	assertThreadStaysAlive(t);
295		t.interrupt();
296	<	t.join();
296	>	awaitTermination(t);
297		assertEquals(SIZE, q.size());
298		assertEquals(0, q.remainingCapacity());
299		}
300
301		/**
302	<	* put blocks waiting for take when full
302	>	* put blocks interruptibly waiting for take when full
303		*/
304		public void testPutWithTake() throws InterruptedException {
305		final int capacity = 2;
306		final ArrayBlockingQueue q = new ArrayBlockingQueue(capacity);
307	<	Thread t = new Thread(new CheckedRunnable() {
307	>	final CountDownLatch pleaseTake = new CountDownLatch(1);
308	>	final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
309	>	Thread t = newStartedThread(new CheckedRunnable() {
310		public void realRun() throws InterruptedException {
311	<	for (int i = 0; i < capacity + 1; i++)
311	>	for (int i = 0; i < capacity; i++)
312		q.put(i);
313	+	pleaseTake.countDown();
314	+	q.put(86);
315	+
316	+	pleaseInterrupt.countDown();
317		try {
318		q.put(99);
319		shouldThrow();
320		} catch (InterruptedException success) {}
321	+	assertFalse(Thread.interrupted());
322		}});
323
324	<	t.start();
325	<	delay(SHORT_DELAY_MS);
355	<	assertEquals(q.remainingCapacity(), 0);
324	>	await(pleaseTake);
325	>	assertEquals(0, q.remainingCapacity());
326		assertEquals(0, q.take());
327	<	delay(SHORT_DELAY_MS);
327	>
328	>	await(pleaseInterrupt);
329	>	assertThreadStaysAlive(t);
330		t.interrupt();
331	<	t.join();
332	<	assertEquals(q.remainingCapacity(), 0);
331	>	awaitTermination(t);
332	>	assertEquals(0, q.remainingCapacity());
333		}
334
335		/**
#	Line 365 | Line 337 | public class ArrayBlockingQueueTest exte
337		*/
338		public void testTimedOffer() throws InterruptedException {
339		final ArrayBlockingQueue q = new ArrayBlockingQueue(2);
340	<	Thread t = new Thread(new CheckedRunnable() {
340	>	final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
341	>	Thread t = newStartedThread(new CheckedRunnable() {
342		public void realRun() throws InterruptedException {
343		q.put(new Object());
344		q.put(new Object());
345	<	assertFalse(q.offer(new Object(), SHORT_DELAY_MS/2, MILLISECONDS));
345	>	long startTime = System.nanoTime();
346	>	assertFalse(q.offer(new Object(), timeoutMillis(), MILLISECONDS));
347	>	assertTrue(millisElapsedSince(startTime) >= timeoutMillis());
348	>	pleaseInterrupt.countDown();
349		try {
350	<	q.offer(new Object(), LONG_DELAY_MS, MILLISECONDS);
350	>	q.offer(new Object(), 2 * LONG_DELAY_MS, MILLISECONDS);
351		shouldThrow();
352		} catch (InterruptedException success) {}
353		}});
354
355	<	t.start();
356	<	delay(SHORT_DELAY_MS);
355	>	await(pleaseInterrupt);
356	>	assertThreadStaysAlive(t);
357		t.interrupt();
358	<	t.join();
358	>	awaitTermination(t);
359		}
360
361		/**
#	Line 397 | Line 373 | public class ArrayBlockingQueueTest exte
373		*/
374		public void testBlockingTake() throws InterruptedException {
375		final ArrayBlockingQueue q = populatedQueue(SIZE);
376	<	Thread t = new Thread(new CheckedRunnable() {
376	>	final CountDownLatch pleaseInterrupt = new CountDownLatch(1);
377	>	Thread t = newStartedThread(new CheckedRunnable() {
378		public void realRun() throws InterruptedException {
379		for (int i = 0; i < SIZE; ++i) {
380		assertEquals(i, q.take());
381		}
382	+
383	+	Thread.currentThread().interrupt();
384		try {
385		q.take();
386		shouldThrow();
387		} catch (InterruptedException success) {}
388	+	assertFalse(Thread.interrupted());
389	+
390	+	pleaseInterrupt.countDown();
391	+	try {
392	+	q.take();
393	+	shouldThrow();
394	+	} catch (InterruptedException success) {}
395	+	assertFalse(Thread.interrupted());
396		}});
397
398	<	t.start();
399	<	delay(SHORT_DELAY_MS);
398	>	await(pleaseInterrupt);
399	>	assertThreadStaysAlive(t);
400		t.interrupt();
401	<	t.join();
401	>	awaitTermination(t);
402		}
403
417	–
404		/**
405		* poll succeeds unless empty
406		*/
#	Line 435 | Line 421 | public class ArrayBlockingQueueTest exte
421		assertEquals(i, q.poll(0, MILLISECONDS));
422		}
423		assertNull(q.poll(0, MILLISECONDS));
424	+	checkEmpty(q);
425		}
426
427		/**
#	Line 443 | Line 430 | public class ArrayBlockingQueueTest exte
430		public void testTimedPoll() throws InterruptedException {
431		ArrayBlockingQueue q = populatedQueue(SIZE);
432		for (int i = 0; i < SIZE; ++i) {
433	<	assertEquals(i, q.poll(SHORT_DELAY_MS, MILLISECONDS));
434	<	}
435	<	assertNull(q.poll(SHORT_DELAY_MS, MILLISECONDS));
433	>	long startTime = System.nanoTime();
434	>	assertEquals(i, q.poll(LONG_DELAY_MS, MILLISECONDS));
435	>	assertTrue(millisElapsedSince(startTime) < LONG_DELAY_MS);
436	>	}
437	>	long startTime = System.nanoTime();
438	>	assertNull(q.poll(timeoutMillis(), MILLISECONDS));
439	>	assertTrue(millisElapsedSince(startTime) >= timeoutMillis());
440	>	checkEmpty(q);
441		}
442
443		/**
#	Line 523 | Line 515 | public class ArrayBlockingQueueTest exte
515		}
516
517		/**
526	–	* remove(x) removes x and returns true if present
527	–	*/
528	–	public void testRemoveElement() {
529	–	ArrayBlockingQueue q = populatedQueue(SIZE);
530	–	for (int i = 1; i < SIZE; i+=2) {
531	–	assertTrue(q.remove(new Integer(i)));
532	–	}
533	–	for (int i = 0; i < SIZE; i+=2) {
534	–	assertTrue(q.remove(new Integer(i)));
535	–	assertFalse(q.remove(new Integer(i+1)));
536	–	}
537	–	assertTrue(q.isEmpty());
538	–	}
539	–
540	–	/**
518		* contains(x) reports true when elements added but not yet removed
519		*/
520		public void testContains() {
#	Line 637 | Line 614 | public class ArrayBlockingQueueTest exte
614		}
615
616		/**
640	–	* toArray(null) throws NullPointerException
641	–	*/
642	–	public void testToArray_NullArg() {
643	–	ArrayBlockingQueue q = populatedQueue(SIZE);
644	–	try {
645	–	q.toArray(null);
646	–	shouldThrow();
647	–	} catch (NullPointerException success) {}
648	–	}
649	–
650	–	/**
617		* toArray(incompatible array type) throws ArrayStoreException
618		*/
619		public void testToArray1_BadArg() {
#	Line 658 | Line 624 | public class ArrayBlockingQueueTest exte
624		} catch (ArrayStoreException success) {}
625		}
626
661	–
627		/**
628		* iterator iterates through all elements
629		*/
#	Line 722 | Line 687 | public class ArrayBlockingQueueTest exte
687		assertEquals(0, q.size());
688		}
689
725	–
690		/**
691		* toString contains toStrings of elements
692		*/
#	Line 730 | Line 694 | public class ArrayBlockingQueueTest exte
694		ArrayBlockingQueue q = populatedQueue(SIZE);
695		String s = q.toString();
696		for (int i = 0; i < SIZE; ++i) {
697	<	assertTrue(s.indexOf(String.valueOf(i)) >= 0);
697	>	assertTrue(s.contains(String.valueOf(i)));
698		}
699		}
700
737	–
701		/**
702		* offer transfers elements across Executor tasks
703		*/
#	Line 743 | Line 706 | public class ArrayBlockingQueueTest exte
706		q.add(one);
707		q.add(two);
708		ExecutorService executor = Executors.newFixedThreadPool(2);
709	+	final CheckedBarrier threadsStarted = new CheckedBarrier(2);
710		executor.execute(new CheckedRunnable() {
711		public void realRun() throws InterruptedException {
712		assertFalse(q.offer(three));
713	<	assertTrue(q.offer(three, MEDIUM_DELAY_MS, MILLISECONDS));
713	>	threadsStarted.await();
714	>	assertTrue(q.offer(three, LONG_DELAY_MS, MILLISECONDS));
715		assertEquals(0, q.remainingCapacity());
716		}});
717
718		executor.execute(new CheckedRunnable() {
719		public void realRun() throws InterruptedException {
720	<	delay(SMALL_DELAY_MS);
720	>	threadsStarted.await();
721	>	assertEquals(0, q.remainingCapacity());
722		assertSame(one, q.take());
723		}});
724
#	Line 760 | Line 726 | public class ArrayBlockingQueueTest exte
726		}
727
728		/**
729	<	* poll retrieves elements across Executor threads
729	>	* timed poll retrieves elements across Executor threads
730		*/
731		public void testPollInExecutor() {
732		final ArrayBlockingQueue q = new ArrayBlockingQueue(2);
733	+	final CheckedBarrier threadsStarted = new CheckedBarrier(2);
734		ExecutorService executor = Executors.newFixedThreadPool(2);
735		executor.execute(new CheckedRunnable() {
736		public void realRun() throws InterruptedException {
737		assertNull(q.poll());
738	<	assertSame(one, q.poll(MEDIUM_DELAY_MS, MILLISECONDS));
739	<	assertTrue(q.isEmpty());
738	>	threadsStarted.await();
739	>	assertSame(one, q.poll(LONG_DELAY_MS, MILLISECONDS));
740	>	checkEmpty(q);
741		}});
742
743		executor.execute(new CheckedRunnable() {
744		public void realRun() throws InterruptedException {
745	<	delay(SMALL_DELAY_MS);
745	>	threadsStarted.await();
746		q.put(one);
747		}});
748
#	Line 785 | Line 753 | public class ArrayBlockingQueueTest exte
753		* A deserialized serialized queue has same elements in same order
754		*/
755		public void testSerialization() throws Exception {
756	<	ArrayBlockingQueue q = populatedQueue(SIZE);
757	<
790	<	ByteArrayOutputStream bout = new ByteArrayOutputStream(10000);
791	<	ObjectOutputStream out = new ObjectOutputStream(new BufferedOutputStream(bout));
792	<	out.writeObject(q);
793	<	out.close();
756	>	Queue x = populatedQueue(SIZE);
757	>	Queue y = serialClone(x);
758
759	<	ByteArrayInputStream bin = new ByteArrayInputStream(bout.toByteArray());
760	<	ObjectInputStream in = new ObjectInputStream(new BufferedInputStream(bin));
761	<	ArrayBlockingQueue r = (ArrayBlockingQueue)in.readObject();
762	<	assertEquals(q.size(), r.size());
763	<	while (!q.isEmpty())
764	<	assertEquals(q.remove(), r.remove());
765	<	}
766	<
767	<	/**
804	<	* drainTo(null) throws NPE
805	<	*/
806	<	public void testDrainToNull() {
807	<	ArrayBlockingQueue q = populatedQueue(SIZE);
808	<	try {
809	<	q.drainTo(null);
810	<	shouldThrow();
811	<	} catch (NullPointerException success) {}
812	<	}
813	<
814	<	/**
815	<	* drainTo(this) throws IAE
816	<	*/
817	<	public void testDrainToSelf() {
818	<	ArrayBlockingQueue q = populatedQueue(SIZE);
819	<	try {
820	<	q.drainTo(q);
821	<	shouldThrow();
822	<	} catch (IllegalArgumentException success) {}
759	>	assertTrue(x != y);
760	>	assertEquals(x.size(), y.size());
761	>	assertEquals(x.toString(), y.toString());
762	>	assertTrue(Arrays.equals(x.toArray(), y.toArray()));
763	>	while (!x.isEmpty()) {
764	>	assertFalse(y.isEmpty());
765	>	assertEquals(x.remove(), y.remove());
766	>	}
767	>	assertTrue(y.isEmpty());
768		}
769
770		/**
#	Line 829 | Line 774 | public class ArrayBlockingQueueTest exte
774		ArrayBlockingQueue q = populatedQueue(SIZE);
775		ArrayList l = new ArrayList();
776		q.drainTo(l);
777	<	assertEquals(q.size(), 0);
778	<	assertEquals(l.size(), SIZE);
777	>	assertEquals(0, q.size());
778	>	assertEquals(SIZE, l.size());
779		for (int i = 0; i < SIZE; ++i)
780		assertEquals(l.get(i), new Integer(i));
781		q.add(zero);
#	Line 840 | Line 785 | public class ArrayBlockingQueueTest exte
785		assertTrue(q.contains(one));
786		l.clear();
787		q.drainTo(l);
788	<	assertEquals(q.size(), 0);
789	<	assertEquals(l.size(), 2);
788	>	assertEquals(0, q.size());
789	>	assertEquals(2, l.size());
790		for (int i = 0; i < 2; ++i)
791		assertEquals(l.get(i), new Integer(i));
792		}
#	Line 867 | Line 812 | public class ArrayBlockingQueueTest exte
812		}
813
814		/**
870	–	* drainTo(null, n) throws NPE
871	–	*/
872	–	public void testDrainToNullN() {
873	–	ArrayBlockingQueue q = populatedQueue(SIZE);
874	–	try {
875	–	q.drainTo(null, 0);
876	–	shouldThrow();
877	–	} catch (NullPointerException success) {}
878	–	}
879	–
880	–	/**
881	–	* drainTo(this, n) throws IAE
882	–	*/
883	–	public void testDrainToSelfN() {
884	–	ArrayBlockingQueue q = populatedQueue(SIZE);
885	–	try {
886	–	q.drainTo(q, 0);
887	–	shouldThrow();
888	–	} catch (IllegalArgumentException success) {}
889	–	}
890	–
891	–	/**
815		* drainTo(c, n) empties first min(n, size) elements of queue into c
816		*/
817		public void testDrainToN() {
#	Line 899 | Line 822 | public class ArrayBlockingQueueTest exte
822		ArrayList l = new ArrayList();
823		q.drainTo(l, i);
824		int k = (i < SIZE) ? i : SIZE;
825	<	assertEquals(l.size(), k);
826	<	assertEquals(q.size(), SIZE-k);
825	>	assertEquals(k, l.size());
826	>	assertEquals(SIZE-k, q.size());
827		for (int j = 0; j < k; ++j)
828		assertEquals(l.get(j), new Integer(j));
829		while (q.poll() != null) ;

Diff Legend

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