Searched refs:timed (Results 1 - 8 of 8) sorted by relevance
/libcore/luni/src/main/java/java/util/concurrent/ |
H A D | CyclicBarrier.java | 165 private int dowait(boolean timed, long nanos) argument 197 // loop until tripped, broken, interrupted, or timed out 200 if (!timed) 222 if (timed && nanos <= 0L) { 322 * interrupted or timed out while the current thread was 392 * interrupted or timed out while the current thread was
|
H A D | SynchronousQueue.java | 144 * @param timed if this operation should timeout 151 abstract E transfer(E e, boolean timed, long nanos); argument 158 * The number of times to spin before blocking in timed waits. 168 * This is greater than timed value because untimed waits spin 175 * rather than to use timed park. A rough estimate suffices. 297 E transfer(E e, boolean timed, long nanos) { argument 325 if (timed && nanos <= 0) { // can't wait 331 SNode m = awaitFulfill(s, timed, nanos); 378 * @param timed true if timed wai 382 awaitFulfill(SNode s, boolean timed, long nanos) argument 613 transfer(E e, boolean timed, long nanos) argument 707 awaitFulfill(QNode s, E e, boolean timed, long nanos) argument [all...] |
H A D | Exchanger.java | 190 * throw TimeoutExceptions in the timed version of the public 273 * timeout, to avoid need for separate timed versions of these 329 * @param timed true if the wait is timed 330 * @param ns if timed, the maximum wait time, else 0L 332 * TIMED_OUT if timed and timed out 334 private final Object arenaExchange(Object item, boolean timed, long ns) { argument 351 long end = (timed && m == 0) ? System.nanoTime() + ns : 0L; 372 (!timed || 427 slotExchange(Object item, boolean timed, long ns) argument [all...] |
H A D | Phaser.java | 754 * @throws TimeoutException if timed out while waiting 1064 final boolean timed; field in class:Phaser.QNode 1072 boolean timed, long nanos) { 1077 this.timed = timed; 1078 this.deadline = timed ? System.nanoTime() + nanos : 0L; 1095 if (timed) { 1110 else if (!timed) 1071 QNode(Phaser phaser, int phase, boolean interruptible, boolean timed, long nanos) argument
|
H A D | AbstractExecutorService.java | 111 boolean timed, long nanos) 132 final long deadline = timed ? System.nanoTime() + nanos : 0L; 150 else if (timed) { 110 doInvokeAny(Collection<? extends Callable<T>> tasks, boolean timed, long nanos) argument
|
H A D | FutureTask.java | 363 * @param timed true if use timed waits 364 * @param nanos time to wait, if timed 367 private int awaitDone(boolean timed, long nanos) argument 369 final long deadline = timed ? System.nanoTime() + nanos : 0L; 391 else if (timed) { 405 * Tries to unlink a timed-out or interrupted wait node to avoid
|
H A D | LinkedTransferQueue.java | 291 * the current thread was interrupted or the wait timed out. On 321 * may arise due to timed out or interrupted waits, or calls to 344 * can occur in practice; for example when a series of short timed 360 * caller is already timed-out, cancelled, or performing a 557 private static final int TIMED = 3; // for timed poll, tryTransfer 664 * @param timed if true, wait only until timeout elapses 665 * @param nanos timeout in nanosecs, used only if timed is true 668 private E awaitMatch(Node s, Node pred, E e, boolean timed, long nanos) { argument 669 final long deadline = timed ? System.nanoTime() + nanos : 0L; 681 if ((w.isInterrupted() || (timed [all...] |
H A D | ThreadPoolExecutor.java | 993 * Performs blocking or timed wait for a task, depending on 1000 * 4. This worker timed out waiting for a task, and timed-out 1003 * both before and after the timed wait, and if the queue is 1025 boolean timed = allowCoreThreadTimeOut || wc > corePoolSize; 1027 if ((wc > maximumPoolSize || (timed && timedOut)) 1035 Runnable r = timed ?
|
Completed in 222 milliseconds