273 |
|
{ |
274 |
|
CompletableFuture<Integer> f = new CompletableFuture<>(); |
275 |
|
checkIncomplete(f); |
276 |
< |
assertTrue(f.cancel(true)); |
277 |
< |
assertTrue(f.cancel(true)); |
276 |
> |
assertTrue(f.cancel(mayInterruptIfRunning)); |
277 |
> |
assertTrue(f.cancel(mayInterruptIfRunning)); |
278 |
> |
assertTrue(f.cancel(!mayInterruptIfRunning)); |
279 |
|
checkCancelled(f); |
280 |
|
}} |
281 |
|
|
907 |
|
|
908 |
|
public void testExceptionally_exceptionalCompletionActionFailed() { |
909 |
|
for (boolean createIncomplete : new boolean[] { true, false }) |
909 |
– |
for (Integer v1 : new Integer[] { 1, null }) |
910 |
|
{ |
911 |
|
final AtomicInteger a = new AtomicInteger(0); |
912 |
|
final CFException ex1 = new CFException(); |
960 |
|
public void testWhenComplete_exceptionalCompletion() { |
961 |
|
for (ExecutionMode m : ExecutionMode.values()) |
962 |
|
for (boolean createIncomplete : new boolean[] { true, false }) |
963 |
– |
for (Integer v1 : new Integer[] { 1, null }) |
963 |
|
{ |
964 |
|
final AtomicInteger a = new AtomicInteger(0); |
965 |
|
final CFException ex = new CFException(); |
1044 |
|
public void testWhenComplete_actionFailedSourceFailed() { |
1045 |
|
for (boolean createIncomplete : new boolean[] { true, false }) |
1046 |
|
for (ExecutionMode m : ExecutionMode.values()) |
1048 |
– |
for (Integer v1 : new Integer[] { 1, null }) |
1047 |
|
{ |
1048 |
|
final AtomicInteger a = new AtomicInteger(0); |
1049 |
|
final CFException ex1 = new CFException(); |
3210 |
|
CompletableFuture<Integer> f = new CompletableFuture<>(); |
3211 |
|
CompletableFuture<Integer> g = new CompletableFuture<>(); |
3212 |
|
CompletableFuture<Integer> nullFuture = (CompletableFuture<Integer>)null; |
3215 |
– |
CompletableFuture<?> h; |
3213 |
|
ThreadExecutor exec = new ThreadExecutor(); |
3214 |
|
|
3215 |
|
Runnable[] throwingActions = { |