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.58 by jsr166, Mon Jun 2 23:10:08 2014 UTC vs.
Revision 1.59 by jsr166, Tue Jun 3 03:54:14 2014 UTC

#	Line 2614 | Line 2614 | public class CompletableFutureTest exten
2614		*/
2615		public void testAllOf_normal() throws Exception {
2616		for (int k = 1; k < 20; ++k) {
2617	<	CompletableFuture<Integer>[] fs = (CompletableFuture<Integer>[]) new CompletableFuture[k];
2617	>	CompletableFuture<Integer>[] fs
2618	>	= (CompletableFuture<Integer>[]) new CompletableFuture[k];
2619		for (int i = 0; i < k; ++i)
2620		fs[i] = new CompletableFuture<>();
2621		CompletableFuture<Void> f = CompletableFuture.allOf(fs);
#	Line 2622 | Line 2623 | public class CompletableFutureTest exten
2623		checkIncomplete(f);
2624		checkIncomplete(CompletableFuture.allOf(fs));
2625		fs[i].complete(one);
2626	+	}
2627	+	checkCompletedNormally(f, null);
2628	+	checkCompletedNormally(CompletableFuture.allOf(fs), null);
2629	+	}
2630	+	}
2631	+
2632	+	public void testAllOf_backwards() throws Exception {
2633	+	for (int k = 1; k < 20; ++k) {
2634	+	CompletableFuture<Integer>[] fs
2635	+	= (CompletableFuture<Integer>[]) new CompletableFuture[k];
2636	+	for (int i = 0; i < k; ++i)
2637	+	fs[i] = new CompletableFuture<>();
2638	+	CompletableFuture<Void> f = CompletableFuture.allOf(fs);
2639	+	for (int i = k - 1; i >= 0; i--) {
2640	+	checkIncomplete(f);
2641	+	checkIncomplete(CompletableFuture.allOf(fs));
2642	+	fs[i].complete(one);
2643		}
2644		checkCompletedNormally(f, null);
2645		checkCompletedNormally(CompletableFuture.allOf(fs), null);

Diff Legend

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