ViewVC Help

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

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

Comparing jsr166/src/test/tck/CompletableFutureTest.java (file contents):
Revision 1.112 by jsr166, Fri Sep 4 19:46:22 2015 UTC vs.
Revision 1.115 by jsr166, Fri Sep 4 20:44:50 2015 UTC

#	Line 3345 | Line 3345 | public class CompletableFutureTest exten
3345		() -> CompletableFuture.anyOf(null, f),
3346
3347		() -> f.obtrudeException(null),
3348	+
3349	+	() -> CompletableFuture.delayedExecutor(1L, SECONDS, null),
3350	+	() -> CompletableFuture.delayedExecutor(1L, null, new ThreadExecutor()),
3351	+	() -> CompletableFuture.delayedExecutor(1L, null),
3352		};
3353
3354		assertThrows(NullPointerException.class, throwingActions);
#	Line 3586 | Line 3590 | public class CompletableFutureTest exten
3590		/**
3591		* delayedExecutor returns an executor that delays submission
3592		*/
3593	<	public void testDelayedExecutor() {
3593	>	public void testDelayedExecutor() throws Exception {
3594		long timeoutMillis = SMALL_DELAY_MS;
3595		Executor d = CompletableFuture.delayedExecutor(timeoutMillis,
3596		MILLISECONDS);
3597		long startTime = System.nanoTime();
3598		CompletableFuture<Integer> f = CompletableFuture.supplyAsync(() -> 1, d);
3599		assertNull(f.getNow(null));
3600	<	try {
3597	<	f.get(LONG_DELAY_MS, MILLISECONDS);
3598	<	} catch (Throwable fail) { threadUnexpectedException(fail); }
3600	>	assertEquals(1, (int) f.get(LONG_DELAY_MS, MILLISECONDS));
3601		assertTrue(millisElapsedSince(startTime) > timeoutMillis/2);
3602		checkCompletedNormally(f, 1);
3603		}
#	Line 3604 | Line 3606 | public class CompletableFutureTest exten
3606		* delayedExecutor for a given executor returns an executor that
3607		* delays submission
3608		*/
3609	<	public void testDelayedExecutor2() {
3609	>	public void testDelayedExecutor2() throws Exception {
3610		long timeoutMillis = SMALL_DELAY_MS;
3611		Executor d = CompletableFuture.delayedExecutor(timeoutMillis,
3612		MILLISECONDS,
#	Line 3612 | Line 3614 | public class CompletableFutureTest exten
3614		long startTime = System.nanoTime();
3615		CompletableFuture<Integer> f = CompletableFuture.supplyAsync(() -> 1, d);
3616		assertNull(f.getNow(null));
3617	<	try {
3616	<	f.get(LONG_DELAY_MS, MILLISECONDS);
3617	<	} catch (Throwable fail) { threadUnexpectedException(fail); }
3617	>	assertEquals(1, (int) f.get(LONG_DELAY_MS, MILLISECONDS));
3618		assertTrue(millisElapsedSince(startTime) > timeoutMillis/2);
3619		checkCompletedNormally(f, 1);
3620		}

Diff Legend

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