| /libcore/ojluni/src/test/java/util/Timer/ |
| D | Purge.java | 39 int cancelled = 0; in main() local
49 cancelled++; in main()
53 if (purged != cancelled) in main()
54 throw new RuntimeException(purged + " != " + cancelled); in main()
|
| /libcore/ojluni/src/main/java/java/util/concurrent/locks/ |
| D | AbstractQueuedSynchronizer.java | 1613 boolean interrupted = false, cancelled = false, rejected = false; in await()
1616 if (cancelled = (node.getAndUnsetStatus(COND) & COND) != 0) in await()
1636 if (cancelled) { in await()
1665 boolean cancelled = false, interrupted = false; in awaitNanos()
1669 if (cancelled = (node.getAndUnsetStatus(COND) & COND) != 0) in awaitNanos()
1676 if (cancelled) { in awaitNanos()
1707 boolean cancelled = false, interrupted = false; in awaitUntil()
1711 if (cancelled = (node.getAndUnsetStatus(COND) & COND) != 0) in awaitUntil()
1718 if (cancelled) { in awaitUntil()
1724 return !cancelled; in awaitUntil()
[all …]
|
| D | AbstractQueuedLongSynchronizer.java | 1247 boolean interrupted = false, cancelled = false, rejected = false; in await()
1250 if (cancelled = (node.getAndUnsetStatus(COND) & COND) != 0) in await()
1270 if (cancelled) { in await()
1299 boolean cancelled = false, interrupted = false; in awaitNanos()
1303 if (cancelled = (node.getAndUnsetStatus(COND) & COND) != 0) in awaitNanos()
1310 if (cancelled) { in awaitNanos()
1341 boolean cancelled = false, interrupted = false; in awaitUntil()
1345 if (cancelled = (node.getAndUnsetStatus(COND) & COND) != 0) in awaitUntil()
1352 if (cancelled) { in awaitUntil()
1358 return !cancelled; in awaitUntil()
[all …]
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | FutureTaskTest.java | 447 final CountDownLatch cancelled = new CountDownLatch(1); in testCancelInterrupt_ThrowsSecurityException() local
452 await(cancelled); in testCancelInterrupt_ThrowsSecurityException()
478 cancelled.countDown(); in testCancelInterrupt_ThrowsSecurityException()
520 final CountDownLatch cancelled = new CountDownLatch(1); in testCancelNoInterrupt() local
525 await(cancelled); in testCancelNoInterrupt()
534 cancelled.countDown(); in testCancelNoInterrupt()
632 final CountDownLatch cancelled = new CountDownLatch(1); in testTimedGet_Cancellation() local
642 await(cancelled); in testTimedGet_Cancellation()
667 cancelled.countDown(); in testTimedGet_Cancellation()
|
| D | ThreadPoolExecutorSubclassTest.java | 58 boolean cancelled; field in ThreadPoolExecutorSubclassTest.CustomTask
75 lock.lock(); try { return cancelled; } finally { lock.unlock() ; } in isCancelled()
81 cancelled = true; in cancel()
124 if (cancelled) in get()
142 if (cancelled) in get()
|
| /libcore/ojluni/src/test/java/util/concurrent/tck/ |
| D | FutureTaskTest.java | 470 final CountDownLatch cancelled = new CountDownLatch(1); in testCancelInterrupt_ThrowsSecurityException() local
475 await(cancelled); in testCancelInterrupt_ThrowsSecurityException()
501 cancelled.countDown(); in testCancelInterrupt_ThrowsSecurityException()
543 final CountDownLatch cancelled = new CountDownLatch(1); in testCancelNoInterrupt() local
548 await(cancelled); in testCancelNoInterrupt()
557 cancelled.countDown(); in testCancelNoInterrupt()
655 final CountDownLatch cancelled = new CountDownLatch(1); in testTimedGet_Cancellation() local
665 await(cancelled); in testTimedGet_Cancellation()
690 cancelled.countDown(); in testTimedGet_Cancellation()
|
| D | ThreadPoolExecutorSubclassTest.java | 80 boolean cancelled; field in ThreadPoolExecutorSubclassTest.CustomTask
97 lock.lock(); try { return cancelled; } finally { lock.unlock() ; } in isCancelled()
103 cancelled = true; in cancel()
146 if (cancelled) in get()
164 if (cancelled) in get()
|
| /libcore/ojluni/src/main/java/java/util/stream/ |
| D | IntPipeline.java | 169 boolean cancelled; in forEachWithCancel()
170 do { } while (!(cancelled = sink.cancellationRequested()) && spl.tryAdvance(adaptedSink)); in forEachWithCancel()
171 return cancelled; in forEachWithCancel()
|
| D | LongPipeline.java | 167 boolean cancelled; in forEachWithCancel()
168 do { } while (!(cancelled = sink.cancellationRequested()) && spl.tryAdvance(adaptedSink)); in forEachWithCancel()
169 return cancelled; in forEachWithCancel()
|
| D | DoublePipeline.java | 166 boolean cancelled; in forEachWithCancel()
167 do { } while (!(cancelled = sink.cancellationRequested()) && spl.tryAdvance(adaptedSink)); in forEachWithCancel()
168 return cancelled; in forEachWithCancel()
|
| D | AbstractPipeline.java | 531 boolean cancelled = p.forEachWithCancel(spliterator, wrappedSink); in copyIntoWithCancel()
533 return cancelled; in copyIntoWithCancel()
|
| D | ReferencePipeline.java | 137 boolean cancelled; in forEachWithCancel()
138 do { } while (!(cancelled = sink.cancellationRequested()) && spliterator.tryAdvance(sink)); in forEachWithCancel()
139 return cancelled; in forEachWithCancel()
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | ScheduledThreadPoolExecutor.java | 294 boolean cancelled = super.cancel(mayInterruptIfRunning); in cancel()
295 if (cancelled && removeOnCancel && heapIndex >= 0) in cancel()
297 return cancelled; in cancel()
|
| D | CompletableFuture.java | 2466 boolean cancelled = (result == null) && in cancel()
2469 return cancelled || isCancelled(); in cancel()
|