Searched refs:timed (Results 1 - 8 of 8) sorted by relevance
/libcore/luni/src/main/java/java/util/concurrent/ |
H A D | CyclicBarrier.java | 164 private int dowait(boolean timed, long nanos) argument 196 // loop until tripped, broken, interrupted, or timed out 199 if (!timed) 221 if (timed && nanos <= 0L) { 321 * interrupted or timed out while the current thread was 391 * interrupted or timed out while the current thread was
|
H A D | SynchronousQueue.java | 143 * @param timed if this operation should timeout 150 abstract Object transfer(Object e, boolean timed, long nanos); argument 157 * The number of times to spin before blocking in timed waits. 167 * This is greater than timed value because untimed waits spin 174 * rather than to use timed park. A rough estimate suffices. 295 Object transfer(Object e, boolean timed, long nanos) { argument 323 if (timed && nanos <= 0) { // can't wait 329 SNode m = awaitFulfill(s, timed, nanos); 376 * @param timed true if timed wai 380 awaitFulfill(SNode s, boolean timed, long nanos) argument 612 transfer(Object e, boolean timed, long nanos) argument 706 awaitFulfill(QNode s, Object e, boolean timed, long nanos) argument [all...] |
H A D | Phaser.java | 755 * @throws TimeoutException if timed out while waiting 1065 final boolean timed; field in class:Phaser.QNode 1073 boolean timed, long nanos) { 1078 this.timed = timed; 1079 this.lastTime = timed ? System.nanoTime() : 0L; 1096 if (timed) { 1113 else if (!timed) 1072 QNode(Phaser phaser, int phase, boolean interruptible, boolean timed, long nanos) argument
|
H A D | AbstractExecutorService.java | 111 boolean timed, long nanos) 132 long lastTime = timed ? System.nanoTime() : 0; 150 else if (timed) { 110 doInvokeAny(Collection<? extends Callable<T>> tasks, boolean timed, long nanos) argument
|
H A D | FutureTask.java | 360 * @param timed true if use timed waits 361 * @param nanos time to wait, if timed 364 private int awaitDone(boolean timed, long nanos) argument 366 long last = timed ? System.nanoTime() : 0L; 386 else if (timed) { 401 * Tries to unlink a timed-out or interrupted wait node to avoid
|
H A D | Exchanger.java | 222 * The number of times to spin before blocking in timed waits. 305 * @param timed true if the wait is timed 306 * @param nanos if timed, the maximum wait time 307 * @return the other thread's item, or CANCEL if interrupted or timed out 309 private Object doExchange(Object item, boolean timed, long nanos) { argument 330 return timed ? 483 * thread. Fails if timed out or interrupted before hole filled. 522 * thread gives up on a timed wait, it is possible that a
|
H A D | LinkedTransferQueue.java | 292 * the current thread was interrupted or the wait timed out. On 322 * may arise due to timed out or interrupted waits, or calls to 345 * can occur in practice; for example when a series of short timed 361 * caller is already timed-out, cancelled, or performing a 558 private static final int TIMED = 3; // for timed poll, tryTransfer 665 * @param timed if true, wait only until timeout elapses 666 * @param nanos timeout in nanosecs, used only if timed is true 669 private E awaitMatch(Node s, Node pred, E e, boolean timed, long nanos) { argument 670 long lastTime = timed ? System.nanoTime() : 0L; 682 if ((w.isInterrupted() || (timed [all...] |
H A D | ThreadPoolExecutor.java | 967 * Performs blocking or timed wait for a task, depending on 974 * 4. This worker timed out waiting for a task, and timed-out 977 * both before and after the timed wait. 996 boolean timed; // Are workers subject to culling? 1000 timed = allowCoreThreadTimeOut || wc > corePoolSize; 1002 if (wc <= maximumPoolSize && ! (timedOut && timed)) 1013 Runnable r = timed ?
|
Completed in 43 milliseconds