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.91 by jsr166, Tue Jun 17 20:34:18 2014 UTC vs.
Revision 1.101 by jsr166, Sun Feb 22 04:34:44 2015 UTC

#	Line 5 | Line 5
5		* http://creativecommons.org/publicdomain/zero/1.0/
6		*/
7
8	<	import junit.framework.*;
8	>	import static java.util.concurrent.TimeUnit.MILLISECONDS;
9	>	import static java.util.concurrent.TimeUnit.SECONDS;
10	>
11	>	import java.util.ArrayList;
12	>	import java.util.List;
13	>	import java.util.Objects;
14		import java.util.concurrent.Callable;
10	–	import java.util.concurrent.Executor;
11	–	import java.util.concurrent.ExecutorService;
12	–	import java.util.concurrent.Executors;
15		import java.util.concurrent.CancellationException;
14	–	import java.util.concurrent.CountDownLatch;
15	–	import java.util.concurrent.ExecutionException;
16	–	import java.util.concurrent.Future;
16		import java.util.concurrent.CompletableFuture;
17		import java.util.concurrent.CompletionException;
18		import java.util.concurrent.CompletionStage;
19	+	import java.util.concurrent.ExecutionException;
20	+	import java.util.concurrent.Executor;
21		import java.util.concurrent.ForkJoinPool;
22		import java.util.concurrent.ForkJoinTask;
23		import java.util.concurrent.TimeoutException;
24		import java.util.concurrent.atomic.AtomicInteger;
24	–	import static java.util.concurrent.TimeUnit.MILLISECONDS;
25	–	import static java.util.concurrent.TimeUnit.SECONDS;
26	–	import java.util.*;
27	–	import java.util.function.Supplier;
28	–	import java.util.function.Consumer;
25		import java.util.function.BiConsumer;
30	–	import java.util.function.Function;
26		import java.util.function.BiFunction;
27	+	import java.util.function.Consumer;
28	+	import java.util.function.Function;
29	+	import java.util.function.Supplier;
30	+
31	+	import junit.framework.Test;
32	+	import junit.framework.TestSuite;
33
34		public class CompletableFutureTest extends JSR166TestCase {
35
#	Line 57 | Line 58 | public class CompletableFutureTest exten
58		}
59
60		<T> void checkCompletedNormally(CompletableFuture<T> f, T value) {
61	<	try {
62	<	assertEquals(value, f.get(LONG_DELAY_MS, MILLISECONDS));
62	<	} catch (Throwable fail) { threadUnexpectedException(fail); }
61	>	checkTimedGet(f, value);
62	>
63		try {
64		assertEquals(value, f.join());
65		} catch (Throwable fail) { threadUnexpectedException(fail); }
#	Line 76 | Line 76 | public class CompletableFutureTest exten
76		}
77
78		void checkCompletedWithWrappedCFException(CompletableFuture<?> f) {
79	+	long startTime = System.nanoTime();
80	+	long timeoutMillis = LONG_DELAY_MS;
81		try {
82	<	f.get(LONG_DELAY_MS, MILLISECONDS);
82	>	f.get(timeoutMillis, MILLISECONDS);
83		shouldThrow();
84		} catch (ExecutionException success) {
85		assertTrue(success.getCause() instanceof CFException);
86		} catch (Throwable fail) { threadUnexpectedException(fail); }
87	+	assertTrue(millisElapsedSince(startTime) < timeoutMillis/2);
88	+
89		try {
90		f.join();
91		shouldThrow();
#	Line 107 | Line 111 | public class CompletableFutureTest exten
111
112		<U> void checkCompletedExceptionallyWithRootCause(CompletableFuture<U> f,
113		Throwable ex) {
114	+	long startTime = System.nanoTime();
115	+	long timeoutMillis = LONG_DELAY_MS;
116		try {
117	<	f.get(LONG_DELAY_MS, MILLISECONDS);
117	>	f.get(timeoutMillis, MILLISECONDS);
118		shouldThrow();
119		} catch (ExecutionException success) {
120		assertSame(ex, success.getCause());
121		} catch (Throwable fail) { threadUnexpectedException(fail); }
122	+	assertTrue(millisElapsedSince(startTime) < timeoutMillis/2);
123	+
124		try {
125		f.join();
126		shouldThrow();
#	Line 158 | Line 166 | public class CompletableFutureTest exten
166		}
167
168		void checkCancelled(CompletableFuture<?> f) {
169	+	long startTime = System.nanoTime();
170	+	long timeoutMillis = LONG_DELAY_MS;
171		try {
172	<	f.get(LONG_DELAY_MS, MILLISECONDS);
172	>	f.get(timeoutMillis, MILLISECONDS);
173		shouldThrow();
174		} catch (CancellationException success) {
175		} catch (Throwable fail) { threadUnexpectedException(fail); }
176	+	assertTrue(millisElapsedSince(startTime) < timeoutMillis/2);
177	+
178		try {
179		f.join();
180		shouldThrow();
#	Line 183 | Line 195 | public class CompletableFutureTest exten
195		}
196
197		void checkCompletedWithWrappedCancellationException(CompletableFuture<?> f) {
198	+	long startTime = System.nanoTime();
199	+	long timeoutMillis = LONG_DELAY_MS;
200		try {
201	<	f.get(LONG_DELAY_MS, MILLISECONDS);
201	>	f.get(timeoutMillis, MILLISECONDS);
202		shouldThrow();
203		} catch (ExecutionException success) {
204		assertTrue(success.getCause() instanceof CancellationException);
205		} catch (Throwable fail) { threadUnexpectedException(fail); }
206	+	assertTrue(millisElapsedSince(startTime) < timeoutMillis/2);
207	+
208		try {
209		f.join();
210		shouldThrow();
#	Line 257 | Line 273 | public class CompletableFutureTest exten
273		{
274		CompletableFuture<Integer> f = new CompletableFuture<>();
275		checkIncomplete(f);
276	<	assertTrue(f.cancel(true));
277	<	assertTrue(f.cancel(true));
276	>	assertTrue(f.cancel(mayInterruptIfRunning));
277	>	assertTrue(f.cancel(mayInterruptIfRunning));
278	>	assertTrue(f.cancel(!mayInterruptIfRunning));
279		checkCancelled(f);
280		}}
281
#	Line 530 | Line 547 | public class CompletableFutureTest exten
547		}
548		}
549
533	–
550		class CompletableFutureInc extends CheckedIntegerAction
551		implements Function<Integer, CompletableFuture<Integer>>
552		{
#	Line 569 | Line 585 | public class CompletableFutureTest exten
585		}
586		}
587
588	+	static final boolean defaultExecutorIsCommonPool
589	+	= ForkJoinPool.getCommonPoolParallelism() > 1;
590	+
591		/**
592		* Permits the testing of parallel code for the 3 different
593		* execution modes without copy/pasting all the test methods.
594		*/
595		enum ExecutionMode {
596	<	DEFAULT {
596	>	SYNC {
597		public void checkExecutionMode() {
598		assertFalse(ThreadExecutor.startedCurrentThread());
599		assertNull(ForkJoinTask.getPool());
#	Line 650 | Line 669 | public class CompletableFutureTest exten
669
670		ASYNC {
671		public void checkExecutionMode() {
672	<	assertSame(ForkJoinPool.commonPool(),
673	<	ForkJoinTask.getPool());
672	>	assertEquals(defaultExecutorIsCommonPool,
673	>	(ForkJoinPool.commonPool() == ForkJoinTask.getPool()));
674		}
675		public CompletableFuture<Void> runAsync(Runnable a) {
676		return CompletableFuture.runAsync(a);
#	Line 875 | Line 894 | public class CompletableFutureTest exten
894		if (!createIncomplete) f.completeExceptionally(ex);
895		final CompletableFuture<Integer> g = f.exceptionally
896		((Throwable t) -> {
897	<	ExecutionMode.DEFAULT.checkExecutionMode();
897	>	ExecutionMode.SYNC.checkExecutionMode();
898		threadAssertSame(t, ex);
899		a.getAndIncrement();
900		return v1;
#	Line 888 | Line 907 | public class CompletableFutureTest exten
907
908		public void testExceptionally_exceptionalCompletionActionFailed() {
909		for (boolean createIncomplete : new boolean[] { true, false })
891	–	for (Integer v1 : new Integer[] { 1, null })
910		{
911		final AtomicInteger a = new AtomicInteger(0);
912		final CFException ex1 = new CFException();
#	Line 897 | Line 915 | public class CompletableFutureTest exten
915		if (!createIncomplete) f.completeExceptionally(ex1);
916		final CompletableFuture<Integer> g = f.exceptionally
917		((Throwable t) -> {
918	<	ExecutionMode.DEFAULT.checkExecutionMode();
918	>	ExecutionMode.SYNC.checkExecutionMode();
919		threadAssertSame(t, ex1);
920		a.getAndIncrement();
921		throw ex2;
#	Line 942 | Line 960 | public class CompletableFutureTest exten
960		public void testWhenComplete_exceptionalCompletion() {
961		for (ExecutionMode m : ExecutionMode.values())
962		for (boolean createIncomplete : new boolean[] { true, false })
945	–	for (Integer v1 : new Integer[] { 1, null })
963		{
964		final AtomicInteger a = new AtomicInteger(0);
965		final CFException ex = new CFException();
#	Line 1027 | Line 1044 | public class CompletableFutureTest exten
1044		public void testWhenComplete_actionFailedSourceFailed() {
1045		for (boolean createIncomplete : new boolean[] { true, false })
1046		for (ExecutionMode m : ExecutionMode.values())
1030	–	for (Integer v1 : new Integer[] { 1, null })
1047		{
1048		final AtomicInteger a = new AtomicInteger(0);
1049		final CFException ex1 = new CFException();
#	Line 1491 | Line 1507 | public class CompletableFutureTest exten
1507		*/
1508		public void testThenAccept_normalCompletion() {
1509		for (ExecutionMode m : ExecutionMode.values())
1494	–	for (boolean createIncomplete : new boolean[] { true, false })
1510		for (Integer v1 : new Integer[] { 1, null })
1511		{
1512		final CompletableFuture<Integer> f = new CompletableFuture<>();
1513	<	final NoopConsumer r = new NoopConsumer(m);
1514	<	if (!createIncomplete) assertTrue(f.complete(v1));
1500	<	final CompletableFuture<Void> g = m.thenAccept(f, r);
1501	<	if (createIncomplete) {
1502	<	checkIncomplete(g);
1503	<	assertTrue(f.complete(v1));
1504	<	}
1513	>	final NoopConsumer[] rs = new NoopConsumer[4];
1514	>	for (int i = 0; i < rs.length; i++) rs[i] = new NoopConsumer(m);
1515
1516	<	checkCompletedNormally(g, null);
1517	<	r.assertValue(v1);
1516	>	final CompletableFuture<Void> h0 = m.thenAccept(f, rs[0]);
1517	>	final CompletableFuture<Void> h1 = m.acceptEither(f, f, rs[1]);
1518	>	checkIncomplete(h0);
1519	>	checkIncomplete(h1);
1520	>	assertTrue(f.complete(v1));
1521	>	final CompletableFuture<Void> h2 = m.thenAccept(f, rs[2]);
1522	>	final CompletableFuture<Void> h3 = m.acceptEither(f, f, rs[3]);
1523	>
1524	>	checkCompletedNormally(h0, null);
1525	>	checkCompletedNormally(h1, null);
1526	>	checkCompletedNormally(h2, null);
1527	>	checkCompletedNormally(h3, null);
1528		checkCompletedNormally(f, v1);
1529	+	for (NoopConsumer r : rs) r.assertValue(v1);
1530		}}
1531
1532		/**
#	Line 1514 | Line 1535 | public class CompletableFutureTest exten
1535		*/
1536		public void testThenAccept_exceptionalCompletion() {
1537		for (ExecutionMode m : ExecutionMode.values())
1517	–	for (boolean createIncomplete : new boolean[] { true, false })
1538		{
1539		final CFException ex = new CFException();
1540		final CompletableFuture<Integer> f = new CompletableFuture<>();
1541	<	final NoopConsumer r = new NoopConsumer(m);
1542	<	if (!createIncomplete) f.completeExceptionally(ex);
1523	<	final CompletableFuture<Void> g = m.thenAccept(f, r);
1524	<	if (createIncomplete) {
1525	<	checkIncomplete(g);
1526	<	f.completeExceptionally(ex);
1527	<	}
1541	>	final NoopConsumer[] rs = new NoopConsumer[4];
1542	>	for (int i = 0; i < rs.length; i++) rs[i] = new NoopConsumer(m);
1543
1544	<	checkCompletedWithWrappedException(g, ex);
1544	>	final CompletableFuture<Void> h0 = m.thenAccept(f, rs[0]);
1545	>	final CompletableFuture<Void> h1 = m.acceptEither(f, f, rs[1]);
1546	>	assertTrue(f.completeExceptionally(ex));
1547	>	final CompletableFuture<Void> h2 = m.thenAccept(f, rs[2]);
1548	>	final CompletableFuture<Void> h3 = m.acceptEither(f, f, rs[3]);
1549	>
1550	>	checkCompletedWithWrappedException(h0, ex);
1551	>	checkCompletedWithWrappedException(h1, ex);
1552	>	checkCompletedWithWrappedException(h2, ex);
1553	>	checkCompletedWithWrappedException(h3, ex);
1554		checkCompletedExceptionally(f, ex);
1555	<	r.assertNotInvoked();
1555	>	for (NoopConsumer r : rs) r.assertNotInvoked();
1556		}}
1557
1558		/**
#	Line 1536 | Line 1560 | public class CompletableFutureTest exten
1560		*/
1561		public void testThenAccept_sourceCancelled() {
1562		for (ExecutionMode m : ExecutionMode.values())
1539	–	for (boolean createIncomplete : new boolean[] { true, false })
1563		for (boolean mayInterruptIfRunning : new boolean[] { true, false })
1564		{
1565		final CompletableFuture<Integer> f = new CompletableFuture<>();
1566	<	final NoopConsumer r = new NoopConsumer(m);
1567	<	if (!createIncomplete) assertTrue(f.cancel(mayInterruptIfRunning));
1545	<	final CompletableFuture<Void> g = m.thenAccept(f, r);
1546	<	if (createIncomplete) {
1547	<	checkIncomplete(g);
1548	<	assertTrue(f.cancel(mayInterruptIfRunning));
1549	<	}
1566	>	final NoopConsumer[] rs = new NoopConsumer[4];
1567	>	for (int i = 0; i < rs.length; i++) rs[i] = new NoopConsumer(m);
1568
1569	<	checkCompletedWithWrappedCancellationException(g);
1569	>	final CompletableFuture<Void> h0 = m.thenAccept(f, rs[0]);
1570	>	final CompletableFuture<Void> h1 = m.acceptEither(f, f, rs[1]);
1571	>	assertTrue(f.cancel(mayInterruptIfRunning));
1572	>	final CompletableFuture<Void> h2 = m.thenAccept(f, rs[2]);
1573	>	final CompletableFuture<Void> h3 = m.acceptEither(f, f, rs[3]);
1574	>
1575	>	checkCompletedWithWrappedCancellationException(h0);
1576	>	checkCompletedWithWrappedCancellationException(h1);
1577	>	checkCompletedWithWrappedCancellationException(h2);
1578	>	checkCompletedWithWrappedCancellationException(h3);
1579		checkCancelled(f);
1580	<	r.assertNotInvoked();
1580	>	for (NoopConsumer r : rs) r.assertNotInvoked();
1581		}}
1582
1583		/**
#	Line 1558 | Line 1585 | public class CompletableFutureTest exten
1585		*/
1586		public void testThenAccept_actionFailed() {
1587		for (ExecutionMode m : ExecutionMode.values())
1561	–	for (boolean createIncomplete : new boolean[] { true, false })
1588		for (Integer v1 : new Integer[] { 1, null })
1589		{
1590		final CompletableFuture<Integer> f = new CompletableFuture<>();
1591	<	final FailingConsumer r = new FailingConsumer(m);
1592	<	if (!createIncomplete) f.complete(v1);
1567	<	final CompletableFuture<Void> g = m.thenAccept(f, r);
1568	<	if (createIncomplete) {
1569	<	checkIncomplete(g);
1570	<	f.complete(v1);
1571	<	}
1591	>	final FailingConsumer[] rs = new FailingConsumer[4];
1592	>	for (int i = 0; i < rs.length; i++) rs[i] = new FailingConsumer(m);
1593
1594	<	checkCompletedWithWrappedCFException(g);
1594	>	final CompletableFuture<Void> h0 = m.thenAccept(f, rs[0]);
1595	>	final CompletableFuture<Void> h1 = m.acceptEither(f, f, rs[1]);
1596	>	assertTrue(f.complete(v1));
1597	>	final CompletableFuture<Void> h2 = m.thenAccept(f, rs[2]);
1598	>	final CompletableFuture<Void> h3 = m.acceptEither(f, f, rs[3]);
1599	>
1600	>	checkCompletedWithWrappedCFException(h0);
1601	>	checkCompletedWithWrappedCFException(h1);
1602	>	checkCompletedWithWrappedCFException(h2);
1603	>	checkCompletedWithWrappedCFException(h3);
1604		checkCompletedNormally(f, v1);
1605		}}
1606
#	Line 1586 | Line 1616 | public class CompletableFutureTest exten
1616		{
1617		final CompletableFuture<Integer> f = new CompletableFuture<>();
1618		final CompletableFuture<Integer> g = new CompletableFuture<>();
1619	<	final SubtractFunction r1 = new SubtractFunction(m);
1620	<	final SubtractFunction r2 = new SubtractFunction(m);
1591	<	final SubtractFunction r3 = new SubtractFunction(m);
1619	>	final SubtractFunction[] rs = new SubtractFunction[6];
1620	>	for (int i = 0; i < rs.length; i++) rs[i] = new SubtractFunction(m);
1621
1622		final CompletableFuture<Integer> fst =  fFirst ? f : g;
1623		final CompletableFuture<Integer> snd = !fFirst ? f : g;
1624		final Integer w1 =  fFirst ? v1 : v2;
1625		final Integer w2 = !fFirst ? v1 : v2;
1626
1627	<	final CompletableFuture<Integer> h1 = m.thenCombine(f, g, r1);
1627	>	final CompletableFuture<Integer> h0 = m.thenCombine(f, g, rs[0]);
1628	>	final CompletableFuture<Integer> h1 = m.thenCombine(fst, fst, rs[1]);
1629		assertTrue(fst.complete(w1));
1630	<	final CompletableFuture<Integer> h2 = m.thenCombine(f, g, r2);
1631	<	checkIncomplete(h1);
1632	<	checkIncomplete(h2);
1633	<	r1.assertNotInvoked();
1634	<	r2.assertNotInvoked();
1630	>	final CompletableFuture<Integer> h2 = m.thenCombine(f, g, rs[2]);
1631	>	final CompletableFuture<Integer> h3 = m.thenCombine(fst, fst, rs[3]);
1632	>	checkIncomplete(h0); rs[0].assertNotInvoked();
1633	>	checkIncomplete(h2); rs[2].assertNotInvoked();
1634	>	checkCompletedNormally(h1, subtract(w1, w1));
1635	>	checkCompletedNormally(h3, subtract(w1, w1));
1636	>	rs[1].assertValue(subtract(w1, w1));
1637	>	rs[3].assertValue(subtract(w1, w1));
1638		assertTrue(snd.complete(w2));
1639	<	final CompletableFuture<Integer> h3 = m.thenCombine(f, g, r3);
1639	>	final CompletableFuture<Integer> h4 = m.thenCombine(f, g, rs[4]);
1640
1641	<	checkCompletedNormally(h1, subtract(v1, v2));
1641	>	checkCompletedNormally(h0, subtract(v1, v2));
1642		checkCompletedNormally(h2, subtract(v1, v2));
1643	<	checkCompletedNormally(h3, subtract(v1, v2));
1644	<	r1.assertValue(subtract(v1, v2));
1645	<	r2.assertValue(subtract(v1, v2));
1646	<	r3.assertValue(subtract(v1, v2));
1643	>	checkCompletedNormally(h4, subtract(v1, v2));
1644	>	rs[0].assertValue(subtract(v1, v2));
1645	>	rs[2].assertValue(subtract(v1, v2));
1646	>	rs[4].assertValue(subtract(v1, v2));
1647	>
1648		checkCompletedNormally(f, v1);
1649		checkCompletedNormally(g, v2);
1650		}}
#	Line 2957 | Line 2991 | public class CompletableFutureTest exten
2991		checkCancelled(f);
2992		}}
2993
2994	+	/**
2995	+	* thenCompose result completes exceptionally if the result of the action does
2996	+	*/
2997	+	public void testThenCompose_actionReturnsFailingFuture() {
2998	+	for (ExecutionMode m : ExecutionMode.values())
2999	+	for (int order = 0; order < 6; order++)
3000	+	for (Integer v1 : new Integer[] { 1, null })
3001	+	{
3002	+	final CFException ex = new CFException();
3003	+	final CompletableFuture<Integer> f = new CompletableFuture<>();
3004	+	final CompletableFuture<Integer> g = new CompletableFuture<>();
3005	+	final CompletableFuture<Integer> h;
3006	+	// Test all permutations of orders
3007	+	switch (order) {
3008	+	case 0:
3009	+	assertTrue(f.complete(v1));
3010	+	assertTrue(g.completeExceptionally(ex));
3011	+	h = m.thenCompose(f, (x -> g));
3012	+	break;
3013	+	case 1:
3014	+	assertTrue(f.complete(v1));
3015	+	h = m.thenCompose(f, (x -> g));
3016	+	assertTrue(g.completeExceptionally(ex));
3017	+	break;
3018	+	case 2:
3019	+	assertTrue(g.completeExceptionally(ex));
3020	+	assertTrue(f.complete(v1));
3021	+	h = m.thenCompose(f, (x -> g));
3022	+	break;
3023	+	case 3:
3024	+	assertTrue(g.completeExceptionally(ex));
3025	+	h = m.thenCompose(f, (x -> g));
3026	+	assertTrue(f.complete(v1));
3027	+	break;
3028	+	case 4:
3029	+	h = m.thenCompose(f, (x -> g));
3030	+	assertTrue(f.complete(v1));
3031	+	assertTrue(g.completeExceptionally(ex));
3032	+	break;
3033	+	case 5:
3034	+	h = m.thenCompose(f, (x -> g));
3035	+	assertTrue(f.complete(v1));
3036	+	assertTrue(g.completeExceptionally(ex));
3037	+	break;
3038	+	default: throw new AssertionError();
3039	+	}
3040	+
3041	+	checkCompletedExceptionally(g, ex);
3042	+	checkCompletedWithWrappedException(h, ex);
3043	+	checkCompletedNormally(f, v1);
3044	+	}}
3045	+
3046		// other static methods
3047
3048		/**
#	Line 3124 | Line 3210 | public class CompletableFutureTest exten
3210		CompletableFuture<Integer> f = new CompletableFuture<>();
3211		CompletableFuture<Integer> g = new CompletableFuture<>();
3212		CompletableFuture<Integer> nullFuture = (CompletableFuture<Integer>)null;
3127	–	CompletableFuture<?> h;
3213		ThreadExecutor exec = new ThreadExecutor();
3214
3215		Runnable[] throwingActions = {
3216		() -> CompletableFuture.supplyAsync(null),
3217		() -> CompletableFuture.supplyAsync(null, exec),
3218	<	() -> CompletableFuture.supplyAsync(new IntegerSupplier(ExecutionMode.DEFAULT, 42), null),
3218	>	() -> CompletableFuture.supplyAsync(new IntegerSupplier(ExecutionMode.SYNC, 42), null),
3219
3220		() -> CompletableFuture.runAsync(null),
3221		() -> CompletableFuture.runAsync(null, exec),

Diff Legend

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