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

/libcore/ojluni/src/main/java/java/util/concurrent/
H A DCyclicBarrier.java199 private int dowait(boolean timed, long nanos) argument
231 // loop until tripped, broken, interrupted, or timed out
234 if (!timed)
256 if (timed && nanos <= 0L) {
356 * interrupted or timed out while the current thread was
427 * interrupted or timed out while the current thread was
H A DSynchronousQueue.java179 * @param timed if this operation should timeout
186 abstract E transfer(E e, boolean timed, long nanos); argument
190 * The number of times to spin before blocking in timed waits.
201 * This is greater than timed value because untimed waits spin
208 * rather than to use timed park. A rough estimate suffices.
328 E transfer(E e, boolean timed, long nanos) { argument
356 if (timed && nanos <= 0L) { // can't wait
362 SNode m = awaitFulfill(s, timed, nanos);
409 * @param timed true if timed wai
413 awaitFulfill(SNode s, boolean timed, long nanos) argument
641 transfer(E e, boolean timed, long nanos) argument
735 awaitFulfill(QNode s, E e, boolean timed, long nanos) argument
[all...]
H A DExchanger.java217 * throw TimeoutExceptions in the timed version of the public
300 * timeout, to avoid need for separate timed versions of these
353 * @param timed true if the wait is timed
354 * @param ns if timed, the maximum wait time, else 0L
356 * TIMED_OUT if timed and timed out
358 private final Object arenaExchange(Object item, boolean timed, long ns) { argument
375 long end = (timed && m == 0) ? System.nanoTime() + ns : 0L;
396 (!timed ||
451 slotExchange(Object item, boolean timed, long ns) argument
[all...]
H A DPhaser.java779 * @throws TimeoutException if timed out while waiting
1088 final boolean timed; field in class:Phaser.QNode
1096 boolean timed, long nanos) {
1101 this.timed = timed;
1102 this.deadline = timed ? System.nanoTime() + nanos : 0L;
1119 if (timed &&
1129 if (timed)
1095 QNode(Phaser phaser, int phase, boolean interruptible, boolean timed, long nanos) argument
H A DAbstractExecutorService.java148 boolean timed, long nanos)
169 final long deadline = timed ? System.nanoTime() + nanos : 0L;
187 else if (timed) {
147 doInvokeAny(Collection<? extends Callable<T>> tasks, boolean timed, long nanos) argument
H A DFutureTask.java391 * @param timed true if use timed waits
392 * @param nanos time to wait, if timed
395 private int awaitDone(boolean timed, long nanos) argument
423 if (timed && nanos <= 0L)
430 else if (timed) {
455 * Tries to unlink a timed-out or interrupted wait node to avoid
H A DThreadPoolExecutor.java1048 * Performs blocking or timed wait for a task, depending on
1055 * 4. This worker timed out waiting for a task, and timed-out
1058 * both before and after the timed wait, and if the queue is
1080 boolean timed = allowCoreThreadTimeOut || wc > corePoolSize;
1082 if ((wc > maximumPoolSize || (timed && timedOut))
1090 Runnable r = timed ?
H A DLinkedTransferQueue.java323 * the current thread was interrupted or the wait timed out. On
353 * may arise due to timed out or interrupted waits, or calls to
376 * can occur in practice; for example when a series of short timed
392 * caller is already timed-out, cancelled, or performing a
587 private static final int TIMED = 3; // for timed poll, tryTransfer
689 * @param timed if true, wait only until timeout elapses
690 * @param nanos timeout in nanosecs, used only if timed is true
693 private E awaitMatch(Node s, Node pred, E e, boolean timed, long nanos) { argument
694 final long deadline = timed ? System.nanoTime() + nanos : 0L;
707 else if (w.isInterrupted() || (timed
[all...]

Completed in 291 milliseconds