Searched refs:interruptible (Results 1 – 8 of 8) sorted by relevance
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | Phaser.java | 1074 if (node.wasInterrupted && !node.interruptible) in internalAwaitAdvance()
1089 final boolean interruptible; field in Phaser.QNode
1097 QNode(Phaser phaser, int phase, boolean interruptible, in QNode() argument
1101 this.interruptible = interruptible; in QNode()
1117 if (wasInterrupted && interruptible) { in isReleasable()
|
| D | ForkJoinTask.java | 400 boolean interruptible, boolean timed, in awaitDone() argument
420 if (interruptible && Thread.interrupted()) in awaitDone()
459 if (interruptible) { in awaitDone()
|
| D | CompletableFuture.java | 1810 final boolean interruptible; field in CompletableFuture.Signaller
1814 Signaller(boolean interruptible, long nanos, long deadline) { in Signaller() argument
1816 this.interruptible = interruptible; in Signaller()
1831 return ((interrupted && interruptible) || in isReleasable()
1853 private Object waitingGet(boolean interruptible) { in waitingGet() argument
1854 if (interruptible && Thread.interrupted()) in waitingGet()
1861 q = new Signaller(interruptible, 0L, 0L); in waitingGet()
1867 else if (interruptible && q.interrupted) { in waitingGet()
|
| D | ForkJoinPool.java | 2016 final int helpQuiescePool(WorkQueue w, long nanos, boolean interruptible) {
2082 else if ((interrupted = interruptible && Thread.interrupted()) ||
2103 final int externalHelpQuiescePool(long nanos, boolean interruptible) {
2118 else if (interruptible && Thread.interrupted())
|
| /libcore/ojluni/src/main/java/java/util/concurrent/locks/ |
| D | AbstractQueuedSynchronizer.java | 637 boolean interruptible, boolean timed, long time) { in acquire() argument
721 if ((interrupted |= Thread.interrupted()) && interruptible) in acquire()
725 return cancelAcquire(node, interrupted, interruptible); in acquire()
771 boolean interruptible) { in cancelAcquire() argument
779 if (interruptible) in cancelAcquire()
|
| D | StampedLock.java | 1201 private long acquireWrite(boolean interruptible, boolean timed, long time) { in acquireWrite() argument
1257 if ((interrupted |= Thread.interrupted()) && interruptible) in acquireWrite()
1273 private long acquireRead(boolean interruptible, boolean timed, long time) { in acquireRead() argument
1322 if ((interrupted && interruptible) || in acquireRead()
1384 if ((interrupted |= Thread.interrupted()) && interruptible) in acquireRead()
|
| D | AbstractQueuedLongSynchronizer.java | 272 boolean interruptible, boolean timed, long time) { in acquire() argument
356 if ((interrupted |= Thread.interrupted()) && interruptible) in acquire()
360 return cancelAcquire(node, interrupted, interruptible); in acquire()
405 boolean interruptible) { in cancelAcquire() argument
413 if (interruptible) in cancelAcquire()
|
| /libcore/ojluni/src/main/java/sun/nio/fs/ |
| D | UnixCopyFile.java | 52 boolean interruptible; field in UnixCopyFile.Flags
86 flags.interruptible = true; in fromCopyOptions()
579 if (!flags.interruptible) { in copy()
|