ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/CompletableFutureTest.java
(Generate patch)

Comparing jsr166/src/test/tck/CompletableFutureTest.java (file contents):
Revision 1.156 by jsr166, Sun Jun 26 23:45:46 2016 UTC vs.
Revision 1.159 by jsr166, Mon Jun 27 21:39:37 2016 UTC

# Line 4143 | Line 4143 | public class CompletableFutureTest exten
4143       * A demo of scalability - runtime is O(n).
4144       */
4145      public void testManyDependents() throws Throwable {
4146 <        final int n = 1_000;
4146 >        final int n = expensiveTests ? 1_000_000 : 10;
4147          final CompletableFuture<Void> head = new CompletableFuture<>();
4148          final CompletableFuture<Void> complete = CompletableFuture.completedFuture((Void)null);
4149          final AtomicInteger count = new AtomicInteger(0);
# Line 4170 | Line 4170 | public class CompletableFutureTest exten
4170          assertEquals(5 * 3 * n, count.get());
4171      }
4172  
4173 <    /** a66 -Dvmoptions=-Xmx8m -Djsr166.tckTestClass=CompletableFutureTest tck */
4173 >    /** ant -Dvmoptions=-Xmx8m -Djsr166.tckTestClass=CompletableFutureTest tck */
4174      public void testCoCompletionGarbage() throws Throwable {
4175 <        // final int n = 3_000_000;
4176 <        final int n = 100;
4175 >        final int n = expensiveTests ? 1_000_000 : 10;
4176          final CompletableFuture<Integer> incomplete = new CompletableFuture<>();
4177          CompletableFuture<Integer> f;
4178          for (int i = 0; i < n; i++) {
# Line 4213 | Line 4212 | public class CompletableFutureTest exten
4212          }
4213      }
4214  
4215 +    /*
4216 +     * Tests below currently fail in stress mode due to memory retention.
4217 +     * ant -Dvmoptions=-Xmx8m -Djsr166.expensiveTests=true -Djsr166.tckTestClass=CompletableFutureTest tck
4218 +     */
4219 +
4220 +    /** Checks for garbage retention with anyOf. */
4221 +    public void testAnyOfGarbageRetention() throws Throwable {
4222 +        for (Integer v : new Integer[] { 1, null })
4223 +    {
4224 +        final int n = expensiveTests ? 100_000 : 10;
4225 +        CompletableFuture<Integer>[] fs
4226 +            = (CompletableFuture<Integer>[]) new CompletableFuture<?>[100];
4227 +        for (int i = 0; i < fs.length; i++)
4228 +            fs[i] = new CompletableFuture<>();
4229 +        fs[fs.length - 1].complete(v);
4230 +        for (int i = 0; i < n; i++)
4231 +            checkCompletedNormally(CompletableFuture.anyOf(fs), v);
4232 +    }}
4233 +
4234 +    /** Checks for garbage retention with allOf. */
4235 +    public void testCancelledAllOfGarbageRetention() throws Throwable {
4236 +        final int n = expensiveTests ? 100_000 : 10;
4237 +        CompletableFuture<Integer>[] fs
4238 +            = (CompletableFuture<Integer>[]) new CompletableFuture<?>[100];
4239 +        for (int i = 0; i < fs.length; i++)
4240 +            fs[i] = new CompletableFuture<>();
4241 +        for (int i = 0; i < n; i++)
4242 +            assertTrue(CompletableFuture.allOf(fs).cancel(false));
4243 +    }
4244 +
4245   //     static <U> U join(CompletionStage<U> stage) {
4246   //         CompletableFuture<U> f = new CompletableFuture<>();
4247   //         stage.whenComplete((v, ex) -> {

Diff Legend

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