Home
last modified time | relevance | path

Searched refs:timed (Results 1 – 8 of 8) sorted by relevance

/libcore/luni/src/main/java/java/util/concurrent/
DSynchronousQueue.java151 abstract E transfer(E e, boolean timed, long nanos); in transfer() argument
297 E transfer(E e, boolean timed, long nanos) { in transfer() argument
325 if (timed && nanos <= 0) { // can't wait in transfer()
331 SNode m = awaitFulfill(s, timed, nanos); in transfer()
382 SNode awaitFulfill(SNode s, boolean timed, long nanos) { in awaitFulfill() argument
405 final long deadline = timed ? System.nanoTime() + nanos : 0L; in awaitFulfill()
408 (timed ? maxTimedSpins : maxUntimedSpins) : 0); in awaitFulfill()
415 if (timed) { in awaitFulfill()
426 else if (!timed) in awaitFulfill()
613 E transfer(E e, boolean timed, long nanos) { in transfer() argument
[all …]
DExchanger.java334 private final Object arenaExchange(Object item, boolean timed, long ns) { in arenaExchange() argument
351 long end = (timed && m == 0) ? System.nanoTime() + ns : 0L; in arenaExchange()
372 (!timed || in arenaExchange()
390 if (timed && m == 0 && ns <= 0L) in arenaExchange()
427 private final Object slotExchange(Object item, boolean timed, long ns) { in slotExchange() argument
460 long end = timed ? System.nanoTime() + ns : 0L; in slotExchange()
474 (!timed || (ns = end - System.nanoTime()) > 0L)) { in slotExchange()
483 v = timed && ns <= 0L && !t.isInterrupted() ? TIMED_OUT : null; in slotExchange()
DCyclicBarrier.java165 private int dowait(boolean timed, long nanos) in dowait() argument
200 if (!timed) in dowait()
222 if (timed && nanos <= 0L) { in dowait()
DPhaser.java1064 final boolean timed; field in Phaser.QNode
1072 boolean timed, long nanos) { in QNode() argument
1077 this.timed = timed; in QNode()
1078 this.deadline = timed ? System.nanoTime() + nanos : 0L; in QNode()
1095 if (timed) { in isReleasable()
1110 else if (!timed) in block()
DFutureTask.java367 private int awaitDone(boolean timed, long nanos) in awaitDone() argument
369 final long deadline = timed ? System.nanoTime() + nanos : 0L; in awaitDone()
391 else if (timed) { in awaitDone()
DAbstractExecutorService.java111 boolean timed, long nanos) in doInvokeAny() argument
132 final long deadline = timed ? System.nanoTime() + nanos : 0L; in doInvokeAny()
150 else if (timed) { in doInvokeAny()
DLinkedTransferQueue.java668 private E awaitMatch(Node s, Node pred, E e, boolean timed, long nanos) { in awaitMatch() argument
669 final long deadline = timed ? System.nanoTime() + nanos : 0L; in awaitMatch()
681 if ((w.isInterrupted() || (timed && nanos <= 0)) && in awaitMatch()
699 else if (timed) { in awaitMatch()
DThreadPoolExecutor.java1025 boolean timed = allowCoreThreadTimeOut || wc > corePoolSize; in getTask()
1027 if ((wc > maximumPoolSize || (timed && timedOut)) in getTask()
1035 Runnable r = timed ? in getTask()