Searched refs:timed (Results 1 – 9 of 9) sorted by relevance
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | SynchronousQueue.java | 186 abstract E transfer(E e, boolean timed, long nanos); in transfer() argument
328 E transfer(E e, boolean timed, long nanos) { in transfer() argument
356 if (timed && nanos <= 0L) { // can't wait in transfer()
362 SNode m = awaitFulfill(s, timed, nanos); in transfer()
413 SNode awaitFulfill(SNode s, boolean timed, long nanos) { in awaitFulfill() argument
436 final long deadline = timed ? System.nanoTime() + nanos : 0L; in awaitFulfill()
439 ? (timed ? MAX_TIMED_SPINS : MAX_UNTIMED_SPINS) in awaitFulfill()
447 if (timed) { in awaitFulfill()
458 else if (!timed) in awaitFulfill()
641 E transfer(E e, boolean timed, long nanos) { in transfer() argument
[all …]
|
| D | Exchanger.java | 359 private final Object arenaExchange(Object item, boolean timed, long ns) { in arenaExchange() argument
376 long end = (timed && m == 0) ? System.nanoTime() + ns : 0L; in arenaExchange()
397 (!timed || in arenaExchange()
415 if (timed && m == 0 && ns <= 0L) in arenaExchange()
452 private final Object slotExchange(Object item, boolean timed, long ns) { in slotExchange() argument
485 long end = timed ? System.nanoTime() + ns : 0L; in slotExchange()
499 (!timed || (ns = end - System.nanoTime()) > 0L)) { in slotExchange()
508 v = timed && ns <= 0L && !t.isInterrupted() ? TIMED_OUT : null; in slotExchange()
|
| D | CyclicBarrier.java | 199 private int dowait(boolean timed, long nanos) in dowait() argument
234 if (!timed) in dowait()
256 if (timed && nanos <= 0L) { in dowait()
|
| D | Phaser.java | 1088 final boolean timed; field in Phaser.QNode
1096 boolean timed, long nanos) { in QNode() argument
1101 this.timed = timed; in QNode()
1102 this.deadline = timed ? System.nanoTime() + nanos : 0L; in QNode()
1119 if (timed && in isReleasable()
1129 if (timed) in block()
|
| D | AbstractExecutorService.java | 148 boolean timed, long nanos) in doInvokeAny() argument
169 final long deadline = timed ? System.nanoTime() + nanos : 0L; in doInvokeAny()
187 else if (timed) { in doInvokeAny()
|
| D | FutureTask.java | 395 private int awaitDone(boolean timed, long nanos) in awaitDone() argument
423 if (timed && nanos <= 0L) in awaitDone()
430 else if (timed) { in awaitDone()
|
| D | LinkedTransferQueue.java | 693 private E awaitMatch(Node s, Node pred, E e, boolean timed, long nanos) { in awaitMatch() argument
694 final long deadline = timed ? System.nanoTime() + nanos : 0L; in awaitMatch()
707 else if (w.isInterrupted() || (timed && nanos <= 0L)) { in awaitMatch()
724 else if (timed) { in awaitMatch()
|
| D | ThreadPoolExecutor.java | 1080 boolean timed = allowCoreThreadTimeOut || wc > corePoolSize; in getTask()
1082 if ((wc > maximumPoolSize || (timed && timedOut)) in getTask()
1090 Runnable r = timed ? in getTask()
|
| /libcore/ojluni/annotations/hiddenapi/java/util/concurrent/ |
| D | FutureTask.java | 105 private int awaitDone(boolean timed, long nanos) throws java.lang.InterruptedException { in awaitDone() argument
|