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.166 by jsr166, Sun Jul 3 19:38:19 2016 UTC vs.
Revision 1.174 by jsr166, Wed Sep 21 18:01:06 2016 UTC

#	Line 32 | Line 32 | import java.util.concurrent.ForkJoinPool
32		import java.util.concurrent.ForkJoinTask;
33		import java.util.concurrent.RejectedExecutionException;
34		import java.util.concurrent.TimeoutException;
35	–	import java.util.concurrent.TimeUnit;
35		import java.util.concurrent.atomic.AtomicInteger;
36		import java.util.concurrent.atomic.AtomicReference;
37		import java.util.function.BiConsumer;
#	Line 362 | Line 361 | public class CompletableFutureTest exten
361		checkCompletedNormally(f, "test");
362		}
363
364	<	abstract class CheckedAction {
364	>	abstract static class CheckedAction {
365		int invocationCount = 0;
366		final ExecutionMode m;
367		CheckedAction(ExecutionMode m) { this.m = m; }
#	Line 374 | Line 373 | public class CompletableFutureTest exten
373		void assertInvoked() { assertEquals(1, invocationCount); }
374		}
375
376	<	abstract class CheckedIntegerAction extends CheckedAction {
376	>	abstract static class CheckedIntegerAction extends CheckedAction {
377		Integer value;
378		CheckedIntegerAction(ExecutionMode m) { super(m); }
379		void assertValue(Integer expected) {
#	Line 383 | Line 382 | public class CompletableFutureTest exten
382		}
383		}
384
385	<	class IntegerSupplier extends CheckedAction
385	>	static class IntegerSupplier extends CheckedAction
386		implements Supplier<Integer>
387		{
388		final Integer value;
#	Line 402 | Line 401 | public class CompletableFutureTest exten
401		return (x == null) ? null : x + 1;
402		}
403
404	<	class NoopConsumer extends CheckedIntegerAction
404	>	static class NoopConsumer extends CheckedIntegerAction
405		implements Consumer<Integer>
406		{
407		NoopConsumer(ExecutionMode m) { super(m); }
#	Line 412 | Line 411 | public class CompletableFutureTest exten
411		}
412		}
413
414	<	class IncFunction extends CheckedIntegerAction
414	>	static class IncFunction extends CheckedIntegerAction
415		implements Function<Integer,Integer>
416		{
417		IncFunction(ExecutionMode m) { super(m); }
#	Line 430 | Line 429 | public class CompletableFutureTest exten
429		- ((y == null) ? 99 : y.intValue());
430		}
431
432	<	class SubtractAction extends CheckedIntegerAction
432	>	static class SubtractAction extends CheckedIntegerAction
433		implements BiConsumer<Integer, Integer>
434		{
435		SubtractAction(ExecutionMode m) { super(m); }
#	Line 440 | Line 439 | public class CompletableFutureTest exten
439		}
440		}
441
442	<	class SubtractFunction extends CheckedIntegerAction
442	>	static class SubtractFunction extends CheckedIntegerAction
443		implements BiFunction<Integer, Integer, Integer>
444		{
445		SubtractFunction(ExecutionMode m) { super(m); }
#	Line 450 | Line 449 | public class CompletableFutureTest exten
449		}
450		}
451
452	<	class Noop extends CheckedAction implements Runnable {
452	>	static class Noop extends CheckedAction implements Runnable {
453		Noop(ExecutionMode m) { super(m); }
454		public void run() {
455		invoked();
456		}
457		}
458
459	<	class FailingSupplier extends CheckedAction
459	>	static class FailingSupplier extends CheckedAction
460		implements Supplier<Integer>
461		{
462		final CFException ex;
#	Line 468 | Line 467 | public class CompletableFutureTest exten
467		}
468		}
469
470	<	class FailingConsumer extends CheckedIntegerAction
470	>	static class FailingConsumer extends CheckedIntegerAction
471		implements Consumer<Integer>
472		{
473		final CFException ex;
#	Line 480 | Line 479 | public class CompletableFutureTest exten
479		}
480		}
481
482	<	class FailingBiConsumer extends CheckedIntegerAction
482	>	static class FailingBiConsumer extends CheckedIntegerAction
483		implements BiConsumer<Integer, Integer>
484		{
485		final CFException ex;
#	Line 492 | Line 491 | public class CompletableFutureTest exten
491		}
492		}
493
494	<	class FailingFunction extends CheckedIntegerAction
494	>	static class FailingFunction extends CheckedIntegerAction
495		implements Function<Integer, Integer>
496		{
497		final CFException ex;
#	Line 504 | Line 503 | public class CompletableFutureTest exten
503		}
504		}
505
506	<	class FailingBiFunction extends CheckedIntegerAction
506	>	static class FailingBiFunction extends CheckedIntegerAction
507		implements BiFunction<Integer, Integer, Integer>
508		{
509		final CFException ex;
#	Line 516 | Line 515 | public class CompletableFutureTest exten
515		}
516		}
517
518	<	class FailingRunnable extends CheckedAction implements Runnable {
518	>	static class FailingRunnable extends CheckedAction implements Runnable {
519		final CFException ex;
520		FailingRunnable(ExecutionMode m) { super(m); ex = new CFException(); }
521		public void run() {
#	Line 525 | Line 524 | public class CompletableFutureTest exten
524		}
525		}
526
527	<	class CompletableFutureInc extends CheckedIntegerAction
527	>	static class CompletableFutureInc extends CheckedIntegerAction
528		implements Function<Integer, CompletableFuture<Integer>>
529		{
530		CompletableFutureInc(ExecutionMode m) { super(m); }
#	Line 538 | Line 537 | public class CompletableFutureTest exten
537		}
538		}
539
540	<	class FailingCompletableFutureFunction extends CheckedIntegerAction
540	>	static class FailingCompletableFutureFunction extends CheckedIntegerAction
541		implements Function<Integer, CompletableFuture<Integer>>
542		{
543		final CFException ex;
#	Line 3578 | Line 3577 | public class CompletableFutureTest exten
3577		* copy returns a CompletableFuture that is completed normally,
3578		* with the same value, when source is.
3579		*/
3580	<	public void testCopy() {
3580	>	public void testCopy_normalCompletion() {
3581	>	for (boolean createIncomplete : new boolean[] { true, false })
3582	>	for (Integer v1 : new Integer[] { 1, null })
3583	>	{
3584		CompletableFuture<Integer> f = new CompletableFuture<>();
3585	+	if (!createIncomplete) assertTrue(f.complete(v1));
3586		CompletableFuture<Integer> g = f.copy();
3587	<	checkIncomplete(f);
3588	<	checkIncomplete(g);
3589	<	f.complete(1);
3590	<	checkCompletedNormally(f, 1);
3591	<	checkCompletedNormally(g, 1);
3592	<	}
3587	>	if (createIncomplete) {
3588	>	checkIncomplete(f);
3589	>	checkIncomplete(g);
3590	>	assertTrue(f.complete(v1));
3591	>	}
3592	>	checkCompletedNormally(f, v1);
3593	>	checkCompletedNormally(g, v1);
3594	>	}}
3595
3596		/**
3597		* copy returns a CompletableFuture that is completed exceptionally
3598		* when source is.
3599		*/
3600	<	public void testCopy2() {
3600	>	public void testCopy_exceptionalCompletion() {
3601	>	for (boolean createIncomplete : new boolean[] { true, false })
3602	>	{
3603	>	CFException ex = new CFException();
3604		CompletableFuture<Integer> f = new CompletableFuture<>();
3605	+	if (!createIncomplete) f.completeExceptionally(ex);
3606		CompletableFuture<Integer> g = f.copy();
3607	<	checkIncomplete(f);
3608	<	checkIncomplete(g);
3609	<	CFException ex = new CFException();
3610	<	f.completeExceptionally(ex);
3607	>	if (createIncomplete) {
3608	>	checkIncomplete(f);
3609	>	checkIncomplete(g);
3610	>	f.completeExceptionally(ex);
3611	>	}
3612		checkCompletedExceptionally(f, ex);
3613		checkCompletedWithWrappedException(g, ex);
3614	+	}}
3615	+
3616	+	/**
3617	+	* Completion of a copy does not complete its source.
3618	+	*/
3619	+	public void testCopy_oneWayPropagation() {
3620	+	CompletableFuture<Integer> f = new CompletableFuture<>();
3621	+	assertTrue(f.copy().complete(1));
3622	+	assertTrue(f.copy().complete(null));
3623	+	assertTrue(f.copy().cancel(true));
3624	+	assertTrue(f.copy().cancel(false));
3625	+	assertTrue(f.copy().completeExceptionally(new CFException()));
3626	+	checkIncomplete(f);
3627		}
3628
3629		/**
#	Line 3965 | Line 3988 | public class CompletableFutureTest exten
3988		.collect(Collectors.toList());
3989
3990		List<CompletionStage<Integer>> stages = new ArrayList<>();
3991	<	stages.add(new CompletableFuture<Integer>().minimalCompletionStage());
3991	>	CompletionStage<Integer> min =
3992	>	new CompletableFuture<Integer>().minimalCompletionStage();
3993	>	stages.add(min);
3994	>	stages.add(min.thenApply(x -> x));
3995		stages.add(CompletableFuture.completedStage(1));
3996		stages.add(CompletableFuture.failedStage(new CFException()));
3997
#	Line 4001 | Line 4027 | public class CompletableFutureTest exten
4027		throw new Error("Methods did not throw UOE: " + bugs);
4028		}
4029
4030	+	/**
4031	+	* minimalStage.toCompletableFuture() gives mutable CompletableFuture
4032	+	*/
4033	+	public void testMinimalCompletionStage_toCompletableFuture_mutable() {
4034	+	for (Integer v1 : new Integer[] { 1, null })
4035	+	{
4036	+	CompletableFuture<Integer> f = new CompletableFuture<>();
4037	+	CompletionStage minimal = f.minimalCompletionStage();
4038	+	CompletableFuture<Integer> g = minimal.toCompletableFuture();
4039	+	g.complete(v1);
4040	+	checkCompletedNormally(g, v1);
4041	+	checkIncomplete(f);
4042	+	checkIncomplete(minimal.toCompletableFuture());
4043	+	}}
4044	+
4045	+	/**
4046	+	* minimalStage.toCompletableFuture().join() awaits completion
4047	+	*/
4048	+	public void testMinimalCompletionStage_toCompletableFuture_join() throws Exception {
4049	+	for (boolean createIncomplete : new boolean[] { true, false })
4050	+	for (Integer v1 : new Integer[] { 1, null })
4051	+	{
4052	+	CompletableFuture<Integer> f = new CompletableFuture<>();
4053	+	if (!createIncomplete) assertTrue(f.complete(v1));
4054	+	CompletionStage<Integer> minimal = f.minimalCompletionStage();
4055	+	if (createIncomplete) assertTrue(f.complete(v1));
4056	+	assertEquals(v1, minimal.toCompletableFuture().join());
4057	+	assertEquals(v1, minimal.toCompletableFuture().get());
4058	+	checkCompletedNormally(minimal.toCompletableFuture(), v1);
4059	+	}}
4060	+
4061	+	/** Demo utility method for external reliable toCompletableFuture */
4062	+	static <T> CompletableFuture<T> toCompletableFuture(CompletionStage<T> stage) {
4063	+	CompletableFuture<T> f = new CompletableFuture<>();
4064	+	stage.handle((T t, Throwable ex) -> {
4065	+	if (ex != null) f.completeExceptionally(ex);
4066	+	else f.complete(t);
4067	+	return null;
4068	+	});
4069	+	return f;
4070	+	}
4071	+
4072	+	/** Demo utility method to join a CompletionStage */
4073	+	static <T> T join(CompletionStage<T> stage) {
4074	+	return toCompletableFuture(stage).join();
4075	+	}
4076	+
4077	+	/**
4078	+	* Joining a minimal stage "by hand" works
4079	+	*/
4080	+	public void testMinimalCompletionStage_join_by_hand() {
4081	+	for (boolean createIncomplete : new boolean[] { true, false })
4082	+	for (Integer v1 : new Integer[] { 1, null })
4083	+	{
4084	+	CompletableFuture<Integer> f = new CompletableFuture<>();
4085	+	CompletionStage<Integer> minimal = f.minimalCompletionStage();
4086	+	CompletableFuture<Integer> g = new CompletableFuture<>();
4087	+	if (!createIncomplete) assertTrue(f.complete(v1));
4088	+	minimal.thenAccept((x) -> g.complete(x));
4089	+	if (createIncomplete) assertTrue(f.complete(v1));
4090	+	g.join();
4091	+	checkCompletedNormally(g, v1);
4092	+	checkCompletedNormally(f, v1);
4093	+	assertEquals(v1, join(minimal));
4094	+	}}
4095	+
4096		static class Monad {
4097		static class ZeroException extends RuntimeException {
4098		public ZeroException() { super("monadic zero"); }
#	Line 4242 | Line 4334 | public class CompletableFutureTest exten
4334		}
4335		}
4336
4337	<	/*
4338	<	* Tests below currently fail in stress mode due to memory retention.
4339	<	* ant -Dvmoptions=-Xmx8m -Djsr166.expensiveTests=true -Djsr166.tckTestClass=CompletableFutureTest tck
4337	>	/**
4338	>	* Reproduction recipe for:
4339	>	* 8160402: Garbage retention with CompletableFuture.anyOf
4340	>	* cvs update -D '2016-05-01' ./src/main/java/util/concurrent/CompletableFuture.java && ant -Dvmoptions=-Xmx8m -Djsr166.expensiveTests=true -Djsr166.tckTestClass=CompletableFutureTest -Djsr166.methodFilter=testAnyOfGarbageRetention tck; cvs update -A
4341		*/
4249	–
4250	–	/** Checks for garbage retention with anyOf. */
4342		public void testAnyOfGarbageRetention() throws Throwable {
4343		for (Integer v : new Integer[] { 1, null })
4344		{
#	Line 4261 | Line 4352 | public class CompletableFutureTest exten
4352		checkCompletedNormally(CompletableFuture.anyOf(fs), v);
4353		}}
4354
4355	<	/** Checks for garbage retention with allOf. */
4355	>	/**
4356	>	* Checks for garbage retention with allOf.
4357	>	*
4358	>	* As of 2016-07, fails with OOME:
4359	>	* ant -Dvmoptions=-Xmx8m -Djsr166.expensiveTests=true -Djsr166.tckTestClass=CompletableFutureTest -Djsr166.methodFilter=testCancelledAllOfGarbageRetention tck
4360	>	*/
4361		public void testCancelledAllOfGarbageRetention() throws Throwable {
4362		final int n = expensiveTests ? 100_000 : 10;
4363		CompletableFuture<Integer>[] fs
#	Line 4272 | Line 4368 | public class CompletableFutureTest exten
4368		assertTrue(CompletableFuture.allOf(fs).cancel(false));
4369		}
4370
4371	+	/**
4372	+	* Checks for garbage retention when a dependent future is
4373	+	* cancelled and garbage-collected.
4374	+	* 8161600: Garbage retention when source CompletableFutures are never completed
4375	+	*
4376	+	* As of 2016-07, fails with OOME:
4377	+	* ant -Dvmoptions=-Xmx8m -Djsr166.expensiveTests=true -Djsr166.tckTestClass=CompletableFutureTest -Djsr166.methodFilter=testCancelledGarbageRetention tck
4378	+	*/
4379	+	public void testCancelledGarbageRetention() throws Throwable {
4380	+	final int n = expensiveTests ? 100_000 : 10;
4381	+	CompletableFuture<Integer> neverCompleted = new CompletableFuture<>();
4382	+	for (int i = 0; i < n; i++)
4383	+	assertTrue(neverCompleted.thenRun(() -> {}).cancel(true));
4384	+	}
4385	+
4386		//     static <U> U join(CompletionStage<U> stage) {
4387		//         CompletableFuture<U> f = new CompletableFuture<>();
4388		//         stage.whenComplete((v, ex) -> {

Diff Legend

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