| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | SynchronousQueue.java | 281 boolean isCancelled() { in isCancelled() method in SynchronousQueue.TransferStack.SNode
357 if (h != null && h.isCancelled()) in transfer()
372 if (h.isCancelled()) // already cancelled in transfer()
493 if (past != null && past.isCancelled()) in clean()
498 while ((p = head) != null && p != past && p.isCancelled()) in clean()
504 if (n != null && n.isCancelled()) in clean()
564 boolean isCancelled() { in isCancelled() method in SynchronousQueue.TransferQueue.QNode
782 if (hn != null && hn.isCancelled()) { in clean()
807 !d.isCancelled() || // d not cancelled or in clean()
|
| D | Future.java | 128 boolean isCancelled(); in isCancelled() method
|
| D | FutureTask.java | 157 public boolean isCancelled() { in isCancelled() method in FutureTask
|
| D | ThreadPoolExecutor.java | 1800 if (r instanceof Future<?> && ((Future<?>)r).isCancelled()) in purge()
1808 if (r instanceof Future<?> && ((Future<?>)r).isCancelled()) in purge()
|
| D | ScheduledThreadPoolExecutor.java | 385 t.isCancelled()) { // also remove if already cancelled in onShutdown()
|
| D | ForkJoinTask.java | 887 public final boolean isCancelled() { in isCancelled() method in ForkJoinTask
|
| D | CompletableFuture.java | 2293 return cancelled || isCancelled(); in cancel()
2303 public boolean isCancelled() { in isCancelled() method in CompletableFuture
2758 @Override public boolean isCancelled() { in isCancelled() method in CompletableFuture.MinimalStage
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | FutureTaskTest.java | 84 assertFalse(f.isCancelled()); in checkNotDone()
112 assertFalse(f.isCancelled()); in checkCompletedNormally()
124 assertTrue(f.isCancelled()); in checkCancelled()
149 assertFalse(f.isCancelled()); in checkCompletedAbnormally()
358 assertTrue(task.isCancelled()); in testCancelBeforeRun()
375 assertTrue(task.isCancelled()); in testCancelBeforeRun2()
430 assertTrue(task.isCancelled()); in testCancelInterrupt()
472 assertTrue(task.isCancelled()); in testCancelInterrupt_ThrowsSecurityException()
506 assertTrue(task.isCancelled()); in testCancelInterrupt_taskFails()
533 assertTrue(task.isCancelled()); in testCancelNoInterrupt()
|
| D | ExecutorsTest.java | 218 assertFalse(f.isCancelled()); in testNewSingleThreadScheduledExecutor()
242 assertFalse(f.isCancelled()); in testNewScheduledThreadPool()
268 assertFalse(f.isCancelled()); in testUnconfigurableScheduledExecutorService()
|
| D | ForkJoinTask8Test.java | 85 assertFalse(a.isCancelled()); in testInvokeOnPool()
94 assertFalse(a.isCancelled()); in testInvokeOnPool()
104 assertFalse(a.isCancelled()); in checkNotDone()
123 assertFalse(a.isCancelled()); in checkCompletedNormally()
159 assertFalse(a.isCancelled());
1161 assertFalse(f.isCancelled());
|
| D | ScheduledExecutorSubclassTest.java | 68 public boolean isCancelled() { return task.isCancelled(); } in isCancelled() method in ScheduledExecutorSubclassTest.CustomTask
781 assertFalse(task.isCancelled()); in testShutdownNow_delayedTasks()
845 assertTrue(effectivePeriodicPolicy ^ periodic.isCancelled()); in testShutdown_cancellation()
849 assertTrue(effectiveDelayedPolicy ^ delayed.isCancelled()); in testShutdown_cancellation()
871 assertTrue(periodic.isCancelled()); in testShutdown_cancellation()
1276 assertTrue(futures.get(1).isCancelled());
|
| D | ForkJoinTaskTest.java | 62 assertFalse(a.isCancelled()); in testInvokeOnPool()
71 assertFalse(a.isCancelled()); in testInvokeOnPool()
81 assertFalse(a.isCancelled()); in checkNotDone()
98 assertFalse(a.isCancelled()); in checkCompletedNormally()
132 assertTrue(a.isCancelled());
169 assertFalse(a.isCancelled());
|
| D | ForkJoinPoolTest.java | 438 assertFalse(future.isCancelled()); in testExecuteRunnable()
451 assertFalse(future.isCancelled()); in testSubmitCallable()
464 assertFalse(future.isCancelled()); in testSubmitRunnable()
477 assertFalse(future.isCancelled()); in testSubmitRunnable2()
|
| D | RecursiveTaskTest.java | 63 assertFalse(a.isCancelled()); in checkNotDone()
92 assertFalse(a.isCancelled()); in checkCompletedNormally()
130 assertTrue(a.isCancelled()); in checkCancelled()
157 assertFalse(a.isCancelled()); in checkCompletedAbnormally()
|
| D | ScheduledExecutorTest.java | 729 assertFalse(task.isCancelled()); in testShutdownNow_delayedTasks()
794 assertTrue(effectivePeriodicPolicy ^ periodic.isCancelled()); in testShutdown_cancellation()
798 assertTrue(effectiveDelayedPolicy ^ delayed.isCancelled()); in testShutdown_cancellation()
820 assertTrue(periodic.isCancelled()); in testShutdown_cancellation()
1226 assertTrue(futures.get(1).isCancelled());
|
| D | CountedCompleterTest.java | 60 assertFalse(a.isCancelled()); in testInvokeOnPool()
69 assertFalse(a.isCancelled()); in testInvokeOnPool()
79 assertFalse(a.isCancelled()); in checkNotDone()
92 assertFalse(a.isCancelled()); in checkCompletedNormally()
126 assertTrue(a.isCancelled());
163 assertFalse(a.isCancelled());
|
| D | RecursiveActionTest.java | 66 assertFalse(a.isCancelled()); in checkNotDone()
95 assertFalse(a.isCancelled()); in checkCompletedNormally()
113 assertTrue(a.isCancelled()); in checkCancelled()
140 assertFalse(a.isCancelled()); in checkCompletedAbnormally()
|
| D | AbstractExecutorServiceTest.java | 78 assertFalse(future.isCancelled()); in testExecuteRunnable()
607 assertTrue(futures.get(2).isCancelled());
|
| D | ForkJoinPool8Test.java | 77 assertFalse(a.isCancelled()); in checkNotDone()
106 assertFalse(a.isCancelled()); in checkCompletedNormally()
124 assertTrue(a.isCancelled()); in checkCancelled()
151 assertFalse(a.isCancelled()); in checkCompletedAbnormally()
|
| D | ThreadPoolExecutorSubclassTest.java | 74 public boolean isCancelled() { in isCancelled() method in ThreadPoolExecutorSubclassTest.CustomTask
1903 assertTrue(futures.get(1).isCancelled());
2034 assertTrue(future.isCancelled());
|
| D | ThreadPoolExecutorTest.java | 1910 assertTrue(futures.get(1).isCancelled());
2070 assertTrue(future.isCancelled());
|
| D | CompletableFutureTest.java | 66 assertFalse(f.isCancelled()); in checkIncomplete()
92 assertFalse(f.isCancelled()); in checkCompletedNormally()
147 assertFalse(f.isCancelled()); in checkCompletedExceptionally()
204 assertTrue(f.isCancelled()); in checkCancelled()
|
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| D | CompletedFuture.java | 83 public boolean isCancelled() { in isCancelled() method in CompletedFuture
|
| D | PendingFuture.java | 216 public boolean isCancelled() { in isCancelled() method in PendingFuture
|
| D | UnixAsynchronousServerSocketChannelImpl.java | 212 if (child != null && future.isCancelled()) { in onEvent()
|