ViewVC Help

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

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

Comparing jsr166/src/test/tck/SynchronousQueueTest.java (file contents):
Revision 1.36 by jsr166, Sat May 28 13:40:20 2011 UTC vs.
Revision 1.37 by jsr166, Mon May 30 22:43:20 2011 UTC

#	Line 7 | Line 7
7		*/
8
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.concurrent.BlockingQueue;
16	>	import java.util.concurrent.CountDownLatch;
17	>	import java.util.concurrent.Executors;
18	>	import java.util.concurrent.ExecutorService;
19	>	import java.util.concurrent.SynchronousQueue;
20		import static java.util.concurrent.TimeUnit.MILLISECONDS;
21		import java.io.*;
22
#	Line 50 | Line 58 | public class SynchronousQueueTest extend
58		}
59
60		/**
53	–	* offer(null) throws NullPointerException
54	–	*/
55	–	public void testOfferNull()      { testOfferNull(false); }
56	–	public void testOfferNull_fair() { testOfferNull(true); }
57	–	public void testOfferNull(boolean fair) {
58	–	SynchronousQueue q = new SynchronousQueue(fair);
59	–	try {
60	–	q.offer(null);
61	–	shouldThrow();
62	–	} catch (NullPointerException success) {}
63	–	}
64	–
65	–	/**
66	–	* add(null) throws NullPointerException
67	–	*/
68	–	public void testAddNull()      { testAddNull(false); }
69	–	public void testAddNull_fair() { testAddNull(true); }
70	–	public void testAddNull(boolean fair) {
71	–	SynchronousQueue q = new SynchronousQueue(fair);
72	–	try {
73	–	q.add(null);
74	–	shouldThrow();
75	–	} catch (NullPointerException success) {}
76	–	}
77	–
78	–	/**
61		* offer fails if no active taker
62		*/
63		public void testOffer()      { testOffer(false); }
#	Line 100 | Line 82 | public class SynchronousQueueTest extend
82		}
83
84		/**
103	–	* addAll(null) throws NullPointerException
104	–	*/
105	–	public void testAddAll_null()      { testAddAll_null(false); }
106	–	public void testAddAll_null_fair() { testAddAll_null(true); }
107	–	public void testAddAll_null(boolean fair) {
108	–	SynchronousQueue q = new SynchronousQueue(fair);
109	–	try {
110	–	q.addAll(null);
111	–	shouldThrow();
112	–	} catch (NullPointerException success) {}
113	–	}
114	–
115	–	/**
85		* addAll(this) throws IllegalArgumentException
86		*/
87		public void testAddAll_self()      { testAddAll_self(false); }
#	Line 126 | Line 95 | public class SynchronousQueueTest extend
95		}
96
97		/**
129	–	* addAll of a collection with null elements throws NullPointerException
130	–	*/
131	–	public void testAddAll_null2()      { testAddAll_null2(false); }
132	–	public void testAddAll_null2_fair() { testAddAll_null2(true); }
133	–	public void testAddAll_null2(boolean fair) {
134	–	SynchronousQueue q = new SynchronousQueue(fair);
135	–	Collection<Integer> ints = Arrays.asList(new Integer[1]);
136	–	try {
137	–	q.addAll(ints);
138	–	shouldThrow();
139	–	} catch (NullPointerException success) {}
140	–	}
141	–
142	–	/**
98		* addAll throws ISE if no active taker
99		*/
100		public void testAddAll_ISE()      { testAddAll_ISE(false); }
#	Line 157 | Line 112 | public class SynchronousQueueTest extend
112		}
113
114		/**
160	–	* put(null) throws NPE
161	–	*/
162	–	public void testPutNull() throws InterruptedException {
163	–	try {
164	–	SynchronousQueue q = new SynchronousQueue();
165	–	q.put(null);
166	–	shouldThrow();
167	–	} catch (NullPointerException success) {}
168	–	}
169	–
170	–	/**
115		* put blocks interruptibly if no active taker
116		*/
117		public void testBlockingPut()      { testBlockingPut(false); }
#	Line 591 | Line 535 | public class SynchronousQueueTest extend
535		}
536
537		/**
594	–	* drainTo(null) throws NPE
595	–	*/
596	–	public void testDrainToNull()      { testDrainToNull(false); }
597	–	public void testDrainToNull_fair() { testDrainToNull(true); }
598	–	public void testDrainToNull(boolean fair) {
599	–	final SynchronousQueue q = new SynchronousQueue(fair);
600	–	try {
601	–	q.drainTo(null);
602	–	shouldThrow();
603	–	} catch (NullPointerException success) {}
604	–	}
605	–
606	–	/**
607	–	* drainTo(this) throws IAE
608	–	*/
609	–	public void testDrainToSelf()      { testDrainToSelf(false); }
610	–	public void testDrainToSelf_fair() { testDrainToSelf(true); }
611	–	public void testDrainToSelf(boolean fair) {
612	–	final SynchronousQueue q = new SynchronousQueue(fair);
613	–	try {
614	–	q.drainTo(q);
615	–	shouldThrow();
616	–	} catch (IllegalArgumentException success) {}
617	–	}
618	–
619	–	/**
538		* drainTo(c) of empty queue doesn't transfer elements
539		*/
540		public void testDrainTo()      { testDrainTo(false); }
#	Line 655 | Line 573 | public class SynchronousQueueTest extend
573		}
574
575		/**
658	–	* drainTo(null, n) throws NullPointerException
659	–	*/
660	–	public void testDrainToNullN()      { testDrainToNullN(false); }
661	–	public void testDrainToNullN_fair() { testDrainToNullN(true); }
662	–	public void testDrainToNullN(boolean fair) {
663	–	final SynchronousQueue q = new SynchronousQueue(fair);
664	–	try {
665	–	q.drainTo(null, 0);
666	–	shouldThrow();
667	–	} catch (NullPointerException success) {}
668	–	}
669	–
670	–	/**
671	–	* drainTo(this, n) throws IllegalArgumentException
672	–	*/
673	–	public void testDrainToSelfN()      { testDrainToSelfN(false); }
674	–	public void testDrainToSelfN_fair() { testDrainToSelfN(true); }
675	–	public void testDrainToSelfN(boolean fair) {
676	–	final SynchronousQueue q = new SynchronousQueue(fair);
677	–	try {
678	–	q.drainTo(q, 0);
679	–	shouldThrow();
680	–	} catch (IllegalArgumentException success) {}
681	–	}
682	–
683	–	/**
576		* drainTo(c, n) empties up to n elements of queue into c
577		*/
578		public void testDrainToN() throws InterruptedException {

Diff Legend

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