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<>(); |
3393 |
|
Executor c = ForkJoinPool.commonPool(); |
3394 |
|
if (ForkJoinPool.getCommonPoolParallelism() > 1) |
3395 |
|
assertSame(e, c); |
3396 |
+ |
else |
3397 |
+ |
assertNotSame(e, c); |
3398 |
|
} |
3399 |
|
|
3400 |
|
/** |
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() { |
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 |
|
|
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 |
|
|
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 |
|
} |
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 |
|
|
3594 |
|
CompletableFuture<Integer> f = CompletableFuture.supplyAsync(() -> 1, d); |
3595 |
|
assertNull(f.getNow(null)); |
3596 |
|
try { |
3597 |
< |
f.get(LONG_DELAY_MS, MILLISECONDS); |
3597 |
> |
assertEquals(1, (int) f.get(LONG_DELAY_MS, MILLISECONDS)); |
3598 |
|
} catch (Throwable fail) { threadUnexpectedException(fail); } |
3599 |
|
assertTrue(millisElapsedSince(startTime) > timeoutMillis/2); |
3600 |
|
checkCompletedNormally(f, 1); |
3613 |
|
CompletableFuture<Integer> f = CompletableFuture.supplyAsync(() -> 1, d); |
3614 |
|
assertNull(f.getNow(null)); |
3615 |
|
try { |
3616 |
< |
f.get(LONG_DELAY_MS, MILLISECONDS); |
3616 |
> |
assertEquals(1, (int) f.get(LONG_DELAY_MS, MILLISECONDS)); |
3617 |
|
} catch (Throwable fail) { threadUnexpectedException(fail); } |
3618 |
|
assertTrue(millisElapsedSince(startTime) > timeoutMillis/2); |
3619 |
|
checkCompletedNormally(f, 1); |