ViewVC Help

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

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

Comparing jsr166/src/test/tck/JSR166TestCase.java (file contents):
Revision 1.58 by jsr166, Wed Oct 6 02:11:57 2010 UTC vs.
Revision 1.65 by jsr166, Thu Oct 21 23:22:49 2010 UTC

#	Line 96 | Line 96 | public class JSR166TestCase extends Test
96		private static final boolean useSecurityManager =
97		Boolean.getBoolean("jsr166.useSecurityManager");
98
99	+	protected static final boolean expensiveTests =
100	+	Boolean.getBoolean("jsr166.expensiveTests");
101	+
102	+	/**
103	+	* If true, report on stdout all "slow" tests, that is, ones that
104	+	* take more than profileThreshold milliseconds to execute.
105	+	*/
106	+	private static final boolean profileTests =
107	+	Boolean.getBoolean("jsr166.profileTests");
108	+
109	+	/**
110	+	* The number of milliseconds that tests are permitted for
111	+	* execution without being reported, when profileTests is set.
112	+	*/
113	+	private static final long profileThreshold =
114	+	Long.getLong("jsr166.profileThreshold", 100);
115	+
116	+	protected void runTest() throws Throwable {
117	+	if (profileTests)
118	+	runTestProfiled();
119	+	else
120	+	super.runTest();
121	+	}
122	+
123	+	protected void runTestProfiled() throws Throwable {
124	+	long t0 = System.nanoTime();
125	+	try {
126	+	super.runTest();
127	+	} finally {
128	+	long elapsedMillis =
129	+	(System.nanoTime() - t0) / (1000L * 1000L);
130	+	if (elapsedMillis >= profileThreshold)
131	+	System.out.printf("%n%s: %d%n", toString(), elapsedMillis);
132	+	}
133	+	}
134	+
135		/**
136		* Runs all JSR166 unit tests using junit.textui.TestRunner
137		*/
#	Line 116 | Line 152 | public class JSR166TestCase extends Test
152		System.exit(0);
153		}
154
155	+	public static TestSuite newTestSuite(Object... suiteOrClasses) {
156	+	TestSuite suite = new TestSuite();
157	+	for (Object suiteOrClass : suiteOrClasses) {
158	+	if (suiteOrClass instanceof TestSuite)
159	+	suite.addTest((TestSuite) suiteOrClass);
160	+	else if (suiteOrClass instanceof Class)
161	+	suite.addTest(new TestSuite((Class<?>) suiteOrClass));
162	+	else
163	+	throw new ClassCastException("not a test suite or class");
164	+	}
165	+	return suite;
166	+	}
167	+
168		/**
169	<	* Collects all JSR166 unit tests as one suite
169	>	* Collects all JSR166 unit tests as one suite.
170		*/
171		public static Test suite() {
172	<	TestSuite suite = new TestSuite("JSR166 Unit Tests");
173	<
174	<	suite.addTest(ForkJoinPoolTest.suite());
175	<	suite.addTest(ForkJoinTaskTest.suite());
176	<	suite.addTest(RecursiveActionTest.suite());
177	<	suite.addTest(RecursiveTaskTest.suite());
178	<	suite.addTest(LinkedTransferQueueTest.suite());
179	<	suite.addTest(PhaserTest.suite());
180	<	suite.addTest(ThreadLocalRandomTest.suite());
181	<	suite.addTest(AbstractExecutorServiceTest.suite());
182	<	suite.addTest(AbstractQueueTest.suite());
183	<	suite.addTest(AbstractQueuedSynchronizerTest.suite());
184	<	suite.addTest(AbstractQueuedLongSynchronizerTest.suite());
185	<	suite.addTest(ArrayBlockingQueueTest.suite());
186	<	suite.addTest(ArrayDequeTest.suite());
187	<	suite.addTest(AtomicBooleanTest.suite());
188	<	suite.addTest(AtomicIntegerArrayTest.suite());
189	<	suite.addTest(AtomicIntegerFieldUpdaterTest.suite());
190	<	suite.addTest(AtomicIntegerTest.suite());
191	<	suite.addTest(AtomicLongArrayTest.suite());
192	<	suite.addTest(AtomicLongFieldUpdaterTest.suite());
193	<	suite.addTest(AtomicLongTest.suite());
194	<	suite.addTest(AtomicMarkableReferenceTest.suite());
195	<	suite.addTest(AtomicReferenceArrayTest.suite());
196	<	suite.addTest(AtomicReferenceFieldUpdaterTest.suite());
197	<	suite.addTest(AtomicReferenceTest.suite());
198	<	suite.addTest(AtomicStampedReferenceTest.suite());
199	<	suite.addTest(ConcurrentHashMapTest.suite());
200	<	suite.addTest(ConcurrentLinkedDequeTest.suite());
201	<	suite.addTest(ConcurrentLinkedQueueTest.suite());
202	<	suite.addTest(ConcurrentSkipListMapTest.suite());
203	<	suite.addTest(ConcurrentSkipListSubMapTest.suite());
204	<	suite.addTest(ConcurrentSkipListSetTest.suite());
205	<	suite.addTest(ConcurrentSkipListSubSetTest.suite());
206	<	suite.addTest(CopyOnWriteArrayListTest.suite());
207	<	suite.addTest(CopyOnWriteArraySetTest.suite());
208	<	suite.addTest(CountDownLatchTest.suite());
209	<	suite.addTest(CyclicBarrierTest.suite());
210	<	suite.addTest(DelayQueueTest.suite());
211	<	suite.addTest(EntryTest.suite());
212	<	suite.addTest(ExchangerTest.suite());
213	<	suite.addTest(ExecutorsTest.suite());
214	<	suite.addTest(ExecutorCompletionServiceTest.suite());
215	<	suite.addTest(FutureTaskTest.suite());
216	<	suite.addTest(LinkedBlockingDequeTest.suite());
217	<	suite.addTest(LinkedBlockingQueueTest.suite());
218	<	suite.addTest(LinkedListTest.suite());
219	<	suite.addTest(LockSupportTest.suite());
220	<	suite.addTest(PriorityBlockingQueueTest.suite());
221	<	suite.addTest(PriorityQueueTest.suite());
222	<	suite.addTest(ReentrantLockTest.suite());
223	<	suite.addTest(ReentrantReadWriteLockTest.suite());
224	<	suite.addTest(ScheduledExecutorTest.suite());
225	<	suite.addTest(ScheduledExecutorSubclassTest.suite());
226	<	suite.addTest(SemaphoreTest.suite());
227	<	suite.addTest(SynchronousQueueTest.suite());
228	<	suite.addTest(SystemTest.suite());
229	<	suite.addTest(ThreadLocalTest.suite());
230	<	suite.addTest(ThreadPoolExecutorTest.suite());
231	<	suite.addTest(ThreadPoolExecutorSubclassTest.suite());
232	<	suite.addTest(ThreadTest.suite());
233	<	suite.addTest(TimeUnitTest.suite());
234	<	suite.addTest(TreeMapTest.suite());
235	<	suite.addTest(TreeSetTest.suite());
236	<	suite.addTest(TreeSubMapTest.suite());
188	<	suite.addTest(TreeSubSetTest.suite());
189	<
190	<	return suite;
172	>	return newTestSuite(
173	>	ForkJoinPoolTest.suite(),
174	>	ForkJoinTaskTest.suite(),
175	>	RecursiveActionTest.suite(),
176	>	RecursiveTaskTest.suite(),
177	>	LinkedTransferQueueTest.suite(),
178	>	PhaserTest.suite(),
179	>	ThreadLocalRandomTest.suite(),
180	>	AbstractExecutorServiceTest.suite(),
181	>	AbstractQueueTest.suite(),
182	>	AbstractQueuedSynchronizerTest.suite(),
183	>	AbstractQueuedLongSynchronizerTest.suite(),
184	>	ArrayBlockingQueueTest.suite(),
185	>	ArrayDequeTest.suite(),
186	>	AtomicBooleanTest.suite(),
187	>	AtomicIntegerArrayTest.suite(),
188	>	AtomicIntegerFieldUpdaterTest.suite(),
189	>	AtomicIntegerTest.suite(),
190	>	AtomicLongArrayTest.suite(),
191	>	AtomicLongFieldUpdaterTest.suite(),
192	>	AtomicLongTest.suite(),
193	>	AtomicMarkableReferenceTest.suite(),
194	>	AtomicReferenceArrayTest.suite(),
195	>	AtomicReferenceFieldUpdaterTest.suite(),
196	>	AtomicReferenceTest.suite(),
197	>	AtomicStampedReferenceTest.suite(),
198	>	ConcurrentHashMapTest.suite(),
199	>	ConcurrentLinkedDequeTest.suite(),
200	>	ConcurrentLinkedQueueTest.suite(),
201	>	ConcurrentSkipListMapTest.suite(),
202	>	ConcurrentSkipListSubMapTest.suite(),
203	>	ConcurrentSkipListSetTest.suite(),
204	>	ConcurrentSkipListSubSetTest.suite(),
205	>	CopyOnWriteArrayListTest.suite(),
206	>	CopyOnWriteArraySetTest.suite(),
207	>	CountDownLatchTest.suite(),
208	>	CyclicBarrierTest.suite(),
209	>	DelayQueueTest.suite(),
210	>	EntryTest.suite(),
211	>	ExchangerTest.suite(),
212	>	ExecutorsTest.suite(),
213	>	ExecutorCompletionServiceTest.suite(),
214	>	FutureTaskTest.suite(),
215	>	LinkedBlockingDequeTest.suite(),
216	>	LinkedBlockingQueueTest.suite(),
217	>	LinkedListTest.suite(),
218	>	LockSupportTest.suite(),
219	>	PriorityBlockingQueueTest.suite(),
220	>	PriorityQueueTest.suite(),
221	>	ReentrantLockTest.suite(),
222	>	ReentrantReadWriteLockTest.suite(),
223	>	ScheduledExecutorTest.suite(),
224	>	ScheduledExecutorSubclassTest.suite(),
225	>	SemaphoreTest.suite(),
226	>	SynchronousQueueTest.suite(),
227	>	SystemTest.suite(),
228	>	ThreadLocalTest.suite(),
229	>	ThreadPoolExecutorTest.suite(),
230	>	ThreadPoolExecutorSubclassTest.suite(),
231	>	ThreadTest.suite(),
232	>	TimeUnitTest.suite(),
233	>	TreeMapTest.suite(),
234	>	TreeSetTest.suite(),
235	>	TreeSubMapTest.suite(),
236	>	TreeSubSetTest.suite());
237		}
238
239
#	Line 534 | Line 580 | public class JSR166TestCase extends Test
580		}
581
582		/**
583	<	* Sleep until the timeout has elapsed, or interrupted.
583	>	* Sleeps until the given time has elapsed.
584	>	* Throws AssertionFailedError if interrupted.
585	>	*/
586	>	void sleep(long millis) {
587	>	try {
588	>	Thread.sleep(millis);
589	>	} catch (InterruptedException ie) {
590	>	AssertionFailedError afe =
591	>	new AssertionFailedError("Unexpected InterruptedException");
592	>	afe.initCause(ie);
593	>	throw afe;
594	>	}
595	>	}
596	>
597	>	/**
598	>	* Sleeps until the timeout has elapsed, or interrupted.
599		* Does <em>NOT</em> throw InterruptedException.
600		*/
601		void sleepTillInterrupted(long timeoutMillis) {
#	Line 544 | Line 605 | public class JSR166TestCase extends Test
605		}
606
607		/**
608	+	* Waits up to the specified number of milliseconds for the given
609	+	* thread to enter a wait state: BLOCKED, WAITING, or TIMED_WAITING.
610	+	*/
611	+	void waitForThreadToEnterWaitState(Thread thread, long timeoutMillis) {
612	+	long timeoutNanos = timeoutMillis * 1000L * 1000L;
613	+	long t0 = System.nanoTime();
614	+	for (;;) {
615	+	Thread.State s = thread.getState();
616	+	if (s == Thread.State.BLOCKED ||
617	+	s == Thread.State.WAITING ||
618	+	s == Thread.State.TIMED_WAITING ||
619	+	System.nanoTime() - t0 > timeoutNanos)
620	+	return;
621	+	Thread.yield();
622	+	}
623	+	}
624	+
625	+	/**
626		* Returns a new started daemon Thread running the given runnable.
627		*/
628		Thread newStartedThread(Runnable runnable) {
#	Line 553 | Line 632 | public class JSR166TestCase extends Test
632		return t;
633		}
634
635	+	/**
636	+	* Waits for the specified time (in milliseconds) for the thread
637	+	* to terminate (using {@link Thread#join(long)}), else interrupts
638	+	* the thread (in the hope that it may terminate later) and fails.
639	+	*/
640	+	void awaitTermination(Thread t, long timeoutMillis) {
641	+	try {
642	+	t.join(timeoutMillis);
643	+	} catch (InterruptedException ie) {
644	+	threadUnexpectedException(ie);
645	+	} finally {
646	+	if (t.isAlive()) {
647	+	t.interrupt();
648	+	fail("Test timed out");
649	+	}
650	+	}
651	+	}
652	+
653		// Some convenient Runnable classes
654
655		public abstract class CheckedRunnable implements Runnable {
#	Line 667 | Line 764 | public class JSR166TestCase extends Test
764
765		public Callable<String> latchAwaitingStringTask(final CountDownLatch latch) {
766		return new CheckedCallable<String>() {
767	<	public String realCall() {
767	>	protected String realCall() {
768		try {
769		latch.await();
770		} catch (InterruptedException quittingTime) {}
#	Line 728 | Line 825 | public class JSR166TestCase extends Test
825		}
826		}
827
828	+	public Runnable possiblyInterruptedRunnable(final long timeoutMillis) {
829	+	return new CheckedRunnable() {
830	+	protected void realRun() {
831	+	try {
832	+	Thread.sleep(timeoutMillis);
833	+	} catch (InterruptedException ok) {}
834	+	}};
835	+	}
836	+
837		public class MediumPossiblyInterruptedRunnable extends CheckedRunnable {
838		protected void realRun() {
839		try {
#	Line 753 | Line 859 | public class JSR166TestCase extends Test
859		}
860		}
861
862	+	public interface TrackedRunnable extends Runnable {
863	+	boolean isDone();
864	+	}
865	+
866	+	public static TrackedRunnable trackedRunnable(final long timeoutMillis) {
867	+	return new TrackedRunnable() {
868	+	private volatile boolean done = false;
869	+	public boolean isDone() { return done; }
870	+	public void run() {
871	+	try {
872	+	Thread.sleep(timeoutMillis);
873	+	done = true;
874	+	} catch (InterruptedException ok) {}
875	+	}
876	+	};
877	+	}
878	+
879		public static class TrackedShortRunnable implements Runnable {
880		public volatile boolean done = false;
881		public void run() {
882		try {
883	+	Thread.sleep(SHORT_DELAY_MS);
884	+	done = true;
885	+	} catch (InterruptedException ok) {}
886	+	}
887	+	}
888	+
889	+	public static class TrackedSmallRunnable implements Runnable {
890	+	public volatile boolean done = false;
891	+	public void run() {
892	+	try {
893		Thread.sleep(SMALL_DELAY_MS);
894		done = true;
895		} catch (InterruptedException ok) {}
#	Line 840 | Line 973 | public class JSR166TestCase extends Test
973		ThreadPoolExecutor executor) {}
974		}
975
976	+	/**
977	+	* A CyclicBarrier that fails with AssertionFailedErrors instead
978	+	* of throwing checked exceptions.
979	+	*/
980	+	public class CheckedBarrier extends CyclicBarrier {
981	+	public CheckedBarrier(int parties) { super(parties); }
982	+
983	+	public int await() {
984	+	try {
985	+	return super.await();
986	+	} catch (Exception e) {
987	+	AssertionFailedError afe =
988	+	new AssertionFailedError("Unexpected exception: " + e);
989	+	afe.initCause(e);
990	+	throw afe;
991	+	}
992	+	}
993	+	}
994	+
995		}

Diff Legend

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