--- jsr166/src/test/tck/CompletableFutureTest.java	2016/06/27 02:47:42	1.157
+++ jsr166/src/test/tck/CompletableFutureTest.java	2016/06/28 14:49:48	1.161
@@ -3354,8 +3354,8 @@ public class CompletableFutureTest exten
      * Test submissions to an executor that rejects all tasks.
      */
     public void testRejectingExecutor() {
-        for (Integer v : new Integer[] { 1, null }) {
-
+        for (Integer v : new Integer[] { 1, null })
+    {
         final CountingRejectingExecutor e = new CountingRejectingExecutor();
 
         final CompletableFuture<Integer> complete = CompletableFuture.completedFuture(v);
@@ -3434,9 +3434,7 @@ public class CompletableFutureTest exten
             checkCompletedWithWrappedException(future, e.ex);
 
         assertEquals(futures.size(), e.count.get());
-
-        }
-    }
+    }}
 
     /**
      * Test submissions to an executor that rejects all tasks, but
@@ -3444,10 +3442,10 @@ public class CompletableFutureTest exten
      * explicitly completed.
      */
     public void testRejectingExecutorNeverInvoked() {
+        for (Integer v : new Integer[] { 1, null })
+    {
         final CountingRejectingExecutor e = new CountingRejectingExecutor();
 
-        for (Integer v : new Integer[] { 1, null }) {
-
         final CompletableFuture<Integer> complete = CompletableFuture.completedFuture(v);
         final CompletableFuture<Integer> incomplete = new CompletableFuture<>();
 
@@ -3495,9 +3493,7 @@ public class CompletableFutureTest exten
             checkCompletedNormally(future, null);
 
         assertEquals(0, e.count.get());
-
-        }
-    }
+    }}
 
     /**
      * toCompletableFuture returns this CompletableFuture.
@@ -4143,7 +4139,7 @@ public class CompletableFutureTest exten
      * A demo of scalability - runtime is O(n).
      */
     public void testManyDependents() throws Throwable {
-        final int n = 1_000;
+        final int n = expensiveTests ? 1_000_000 : 10;
         final CompletableFuture<Void> head = new CompletableFuture<>();
         final CompletableFuture<Void> complete = CompletableFuture.completedFuture((Void)null);
         final AtomicInteger count = new AtomicInteger(0);
@@ -4170,10 +4166,9 @@ public class CompletableFutureTest exten
         assertEquals(5 * 3 * n, count.get());
     }
 
-    /** ant -Dvmoptions=-Xmx8m -Djsr166.tckTestClass=CompletableFutureTest tck */
-    public void testCoCompletionGarbage() throws Throwable {
-        // final int n = 3_000_000;
-        final int n = 100;
+    /** ant -Dvmoptions=-Xmx8m -Djsr166.expensiveTests=true -Djsr166.tckTestClass=CompletableFutureTest tck */
+    public void testCoCompletionGarbageRetention() throws Throwable {
+        final int n = expensiveTests ? 1_000_000 : 10;
         final CompletableFuture<Integer> incomplete = new CompletableFuture<>();
         CompletableFuture<Integer> f;
         for (int i = 0; i < n; i++) {
@@ -4213,6 +4208,36 @@ public class CompletableFutureTest exten
         }
     }
 
+    /*
+     * Tests below currently fail in stress mode due to memory retention.
+     * ant -Dvmoptions=-Xmx8m -Djsr166.expensiveTests=true -Djsr166.tckTestClass=CompletableFutureTest tck
+     */
+
+    /** Checks for garbage retention with anyOf. */
+    public void testAnyOfGarbageRetention() throws Throwable {
+        for (Integer v : new Integer[] { 1, null })
+    {
+        final int n = expensiveTests ? 100_000 : 10;
+        CompletableFuture<Integer>[] fs
+            = (CompletableFuture<Integer>[]) new CompletableFuture<?>[100];
+        for (int i = 0; i < fs.length; i++)
+            fs[i] = new CompletableFuture<>();
+        fs[fs.length - 1].complete(v);
+        for (int i = 0; i < n; i++)
+            checkCompletedNormally(CompletableFuture.anyOf(fs), v);
+    }}
+
+    /** Checks for garbage retention with allOf. */
+    public void testCancelledAllOfGarbageRetention() throws Throwable {
+        final int n = expensiveTests ? 100_000 : 10;
+        CompletableFuture<Integer>[] fs
+            = (CompletableFuture<Integer>[]) new CompletableFuture<?>[100];
+        for (int i = 0; i < fs.length; i++)
+            fs[i] = new CompletableFuture<>();
+        for (int i = 0; i < n; i++)
+            assertTrue(CompletableFuture.allOf(fs).cancel(false));
+    }
+
 //     static <U> U join(CompletionStage<U> stage) {
 //         CompletableFuture<U> f = new CompletableFuture<>();
 //         stage.whenComplete((v, ex) -> {