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.57 by jsr166, Mon Oct 4 05:45:19 2010 UTC vs.
Revision 1.62 by jsr166, Mon Oct 11 05:40:41 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	<	* Returns a new started Thread running the given runnable.
608	>	* Returns a new started daemon Thread running the given runnable.
609		*/
610		Thread newStartedThread(Runnable runnable) {
611		Thread t = new Thread(runnable);
612	+	t.setDaemon(true);
613		t.start();
614		return t;
615		}
616
617	+	/**
618	+	* Waits for the specified time (in milliseconds) for the thread
619	+	* to terminate (using {@link Thread#join(long)}), else interrupts
620	+	* the thread (in the hope that it may terminate later) and fails.
621	+	*/
622	+	void awaitTermination(Thread t, long timeoutMillis) {
623	+	try {
624	+	t.join(timeoutMillis);
625	+	} catch (InterruptedException ie) {
626	+	threadUnexpectedException(ie);
627	+	} finally {
628	+	if (t.isAlive()) {
629	+	t.interrupt();
630	+	fail("Test timed out");
631	+	}
632	+	}
633	+	}
634	+
635		// Some convenient Runnable classes
636
637		public abstract class CheckedRunnable implements Runnable {
#	Line 752 | Line 832 | public class JSR166TestCase extends Test
832		}
833		}
834
835	+	public interface TrackedRunnable extends Runnable {
836	+	boolean isDone();
837	+	}
838	+
839	+	public static TrackedRunnable trackedRunnable(final long timeoutMillis) {
840	+	return new TrackedRunnable() {
841	+	private volatile boolean done = false;
842	+	public boolean isDone() { return done; }
843	+	public void run() {
844	+	try {
845	+	Thread.sleep(timeoutMillis);
846	+	done = true;
847	+	} catch (InterruptedException ok) {}
848	+	}
849	+	};
850	+	}
851	+
852		public static class TrackedShortRunnable implements Runnable {
853		public volatile boolean done = false;
854		public void run() {
855		try {
856	+	Thread.sleep(SHORT_DELAY_MS);
857	+	done = true;
858	+	} catch (InterruptedException ok) {}
859	+	}
860	+	}
861	+
862	+	public static class TrackedSmallRunnable implements Runnable {
863	+	public volatile boolean done = false;
864	+	public void run() {
865	+	try {
866		Thread.sleep(SMALL_DELAY_MS);
867		done = true;
868		} catch (InterruptedException ok) {}
#	Line 839 | Line 946 | public class JSR166TestCase extends Test
946		ThreadPoolExecutor executor) {}
947		}
948
949	+	/**
950	+	* A CyclicBarrier that fails with AssertionFailedErrors instead
951	+	* of throwing checked exceptions.
952	+	*/
953	+	public class CheckedBarrier extends CyclicBarrier {
954	+	public CheckedBarrier(int parties) { super(parties); }
955	+
956	+	public int await() {
957	+	try {
958	+	return super.await();
959	+	} catch (Exception e) {
960	+	AssertionFailedError afe =
961	+	new AssertionFailedError("Unexpected exception: " + e);
962	+	afe.initCause(e);
963	+	throw afe;
964	+	}
965	+	}
966	+	}
967	+
968		}

Diff Legend

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