Searched defs:timed (Results 1 - 7 of 7) sorted by relevance
/libcore/ojluni/src/main/java/java/util/concurrent/ |
H A D | AbstractExecutorService.java | 148 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 D | CyclicBarrier.java | 199 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 D | Exchanger.java | 217 * 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 D | FutureTask.java | 391 * @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 D | Phaser.java | 779 * @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 D | LinkedTransferQueue.java | 323 * 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...] |
H A D | SynchronousQueue.java | 179 * @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...] |
Completed in 107 milliseconds