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.157 by jsr166, Mon Jun 27 02:47:42 2016 UTC vs.
Revision 1.158 by jsr166, Mon Jun 27 21:17:49 2016 UTC

# Line 4213 | Line 4213 | public class CompletableFutureTest exten
4213          }
4214      }
4215  
4216 +    /*
4217 +     * Tests below currently fail in stress mode due to memory retention.
4218 +     * ant -Dvmoptions=-Xmx8m -Djsr166.expensiveTests=true -Djsr166.tckTestClass=CompletableFutureTest tck
4219 +     */
4220 +
4221 +    /** Checks for garbage retention with anyOf. */
4222 +    public void testAnyOfGarbageRetention() throws Throwable {
4223 +        for (Integer v : new Integer[] { 1, null })
4224 +    {
4225 +        final int n = expensiveTests ? 100_000 : 10;
4226 +        CompletableFuture<Integer>[] fs
4227 +            = (CompletableFuture<Integer>[]) new CompletableFuture<?>[100];
4228 +        for (int i = 0; i < fs.length; i++)
4229 +            fs[i] = new CompletableFuture<>();
4230 +        fs[fs.length - 1].complete(v);
4231 +        for (int i = 0; i < n; i++)
4232 +            checkCompletedNormally(CompletableFuture.anyOf(fs), v);
4233 +    }}
4234 +
4235 +    /** Checks for garbage retention with allOf. */
4236 +    public void testCancelledAllOfGarbageRetention() throws Throwable {
4237 +        final int n = expensiveTests ? 100_000 : 10;
4238 +        CompletableFuture<Integer>[] fs
4239 +            = (CompletableFuture<Integer>[]) new CompletableFuture<?>[100];
4240 +        for (int i = 0; i < fs.length; i++)
4241 +            fs[i] = new CompletableFuture<>();
4242 +        for (int i = 0; i < n; i++)
4243 +            assertTrue(CompletableFuture.allOf(fs).cancel(false));
4244 +    }
4245 +
4246   //     static <U> U join(CompletionStage<U> stage) {
4247   //         CompletableFuture<U> f = new CompletableFuture<>();
4248   //         stage.whenComplete((v, ex) -> {

Diff Legend

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