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.105 by dl, Thu Sep 3 16:30:05 2015 UTC vs.
Revision 1.112 by jsr166, Fri Sep 4 19:46:22 2015 UTC

# Line 3333 | Line 3333 | public class CompletableFutureTest exten
3333              () -> f.exceptionally(null),
3334  
3335              () -> f.handle(null),
3336 +
3337              () -> CompletableFuture.allOf((CompletableFuture<?>)null),
3338              () -> CompletableFuture.allOf((CompletableFuture<?>[])null),
3339              () -> CompletableFuture.allOf(f, null),
# Line 3384 | Line 3385 | public class CompletableFutureTest exten
3385  
3386      /**
3387       * defaultExecutor by default returns the commonPool if
3388 <     * it supports at least one thread.
3388 >     * it supports more than one thread.
3389       */
3390      public void testDefaultExecutor() {
3391          CompletableFuture<Integer> f = new CompletableFuture<>();
3392          Executor e = f.defaultExecutor();
3393 <        Executor c =  ForkJoinPool.commonPool();
3393 >        Executor c = ForkJoinPool.commonPool();
3394          if (ForkJoinPool.getCommonPoolParallelism() > 1)
3395              assertSame(e, c);
3396 +        else
3397 +            assertNotSame(e, c);
3398      }
3399  
3400      /**
# Line 3479 | Line 3482 | public class CompletableFutureTest exten
3482      }
3483  
3484      /**
3485 <     * failedStage returns a Completionstage completed
3485 >     * failedStage returns a CompletionStage completed
3486       * exceptionally with the given Exception
3487       */
3488      public void testFailedStage() {
# Line 3542 | Line 3545 | public class CompletableFutureTest exten
3545      }
3546  
3547      /**
3548 <     *  orTimeout completes with TimeoutException if not complete
3548 >     * orTimeout completes with TimeoutException if not complete
3549       */
3550      public void testOrTimeout() {
3551          CompletableFuture<Integer> f = new CompletableFuture<>();
3552 <        f.orTimeout(SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
3552 >        f.orTimeout(SHORT_DELAY_MS, MILLISECONDS);
3553          checkCompletedExceptionallyWithTimeout(f);
3554      }
3555  
3556      /**
3557 <     *  orTimeout completes normally if completed before timeout
3557 >     * orTimeout completes normally if completed before timeout
3558       */
3559      public void testOrTimeout2() {
3560          CompletableFuture<Integer> f = new CompletableFuture<>();
3561          f.complete(1);
3562 <        f.orTimeout(SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
3562 >        f.orTimeout(SHORT_DELAY_MS, MILLISECONDS);
3563          checkCompletedNormally(f, 1);
3564      }
3565  
3566      /**
3567 <     *  completeOnTimeout completes with given value if not complete
3567 >     * completeOnTimeout completes with given value if not complete
3568       */
3569      public void testCompleteOnTimeout() {
3570          CompletableFuture<Integer> f = new CompletableFuture<>();
3571 <        f.completeOnTimeout(-1, SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
3571 >        f.completeOnTimeout(-1, SHORT_DELAY_MS, MILLISECONDS);
3572          f.join();
3573          checkCompletedNormally(f, -1);
3574      }
3575  
3576      /**
3577 <     *  completeOnTimeout has no effect if completed within timeout
3577 >     * completeOnTimeout has no effect if completed within timeout
3578       */
3579      public void testCompleteOnTimeout2() {
3580          CompletableFuture<Integer> f = new CompletableFuture<>();
3581          f.complete(1);
3582 <        f.completeOnTimeout(-1, SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
3582 >        f.completeOnTimeout(-1, SHORT_DELAY_MS, MILLISECONDS);
3583          checkCompletedNormally(f, 1);
3584      }
3585  

Diff Legend

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