| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | Exchanger.java | 354 private final Object arenaExchange(Object item, boolean timed, long ns) { in arenaExchange() argument
375 long end = (timed && m == 0) ? System.nanoTime() + ns : 0L; in arenaExchange()
396 (!timed || in arenaExchange()
416 if (timed && m == 0 && ns <= 0L) in arenaExchange()
453 private final Object slotExchange(Object item, boolean timed, long ns) { in slotExchange() argument
486 long end = timed ? System.nanoTime() + ns : 0L; in slotExchange()
500 (!timed || (ns = end - System.nanoTime()) > 0L)) { in slotExchange()
511 v = timed && ns <= 0L && !t.isInterrupted() ? TIMED_OUT : null; in slotExchange()
|
| D | CyclicBarrier.java | 201 private int dowait(boolean timed, long nanos) in dowait() argument
235 if (!timed) in dowait()
257 if (timed && nanos <= 0L) { in dowait()
|
| D | SynchronousQueue.java | 200 abstract E transfer(E e, boolean timed, long nanos); in transfer() argument
338 E transfer(E e, boolean timed, long nanos) { in transfer() argument
366 if (timed && nanos <= 0L) { // can't wait in transfer()
372 long deadline = timed ? System.nanoTime() + nanos : 0L; in transfer()
377 if ((timed && in transfer()
394 } else if (!timed) { in transfer()
629 E transfer(E e, boolean timed, long nanos) { in transfer() argument
666 else if (timed && nanos <= 0L) // can't wait in transfer()
671 long deadline = timed ? System.nanoTime() + nanos : 0L; in transfer()
676 if ((timed && in transfer()
[all …]
|
| D | Phaser.java | 1090 final boolean timed; field in Phaser.QNode
1098 boolean timed, long nanos) { in QNode() argument
1103 this.timed = timed; in QNode()
1104 this.deadline = timed ? System.nanoTime() + nanos : 0L; in QNode()
1121 if (timed && in isReleasable()
1131 if (timed) in block()
|
| D | AbstractExecutorService.java | 153 boolean timed, long nanos) in doInvokeAny() argument
174 final long deadline = timed ? System.nanoTime() + nanos : 0L; in doInvokeAny()
192 else if (timed) { in doInvokeAny()
|
| D | FutureTask.java | 393 private int awaitDone(boolean timed, long nanos) in awaitDone() argument
421 if (timed && nanos <= 0L) in awaitDone()
427 else if (timed) { in awaitDone()
|
| D | SubmissionPublisher.java | 1478 boolean timed = (nanos < Long.MAX_VALUE); in block()
1479 long deadline = timed ? System.nanoTime() + nanos : 0L; in block()
1483 if (timed) in block()
1486 else if (timed && (nanos = deadline - System.nanoTime()) <= 0L) in block()
1492 else if (timed) in block()
|
| D | ThreadPoolExecutor.java | 1059 boolean timed = allowCoreThreadTimeOut || wc > corePoolSize; in getTask()
1061 if ((wc > maximumPoolSize || (timed && timedOut)) in getTask()
1069 Runnable r = timed ? in getTask()
|
| D | LinkedTransferQueue.java | 636 private E awaitMatch(Node s, Node pred, E e, boolean timed, long nanos) { in awaitMatch() argument
638 final long deadline = timed ? System.nanoTime() + nanos : 0L; in awaitMatch()
645 else if ((timed && nanos <= 0L) || w.isInterrupted()) { in awaitMatch()
666 else if (!timed) { in awaitMatch()
|
| D | ForkJoinTask.java | 400 boolean interruptible, boolean timed, in awaitDone() argument
425 if (timed) { in awaitDone()
434 boolean canHelp = !timed || (p.mode & SMASK) == 0; in awaitDone()
|
| /libcore/ojluni/src/main/java/java/util/concurrent/locks/ |
| D | StampedLock.java | 1201 private long acquireWrite(boolean interruptible, boolean timed, long time) { in acquireWrite() argument
1250 if (!timed) in acquireWrite()
1273 private long acquireRead(boolean interruptible, boolean timed, long time) { in acquireRead() argument
1317 if (!timed) in acquireRead()
1323 (timed && nanos <= 0L)) in acquireRead()
1377 if (!timed) in acquireRead()
|
| D | AbstractQueuedLongSynchronizer.java | 272 boolean interruptible, boolean timed, long time) { in acquire() argument
349 if (!timed) in acquire()
|
| D | AbstractQueuedSynchronizer.java | 637 boolean interruptible, boolean timed, long time) { in acquire() argument
714 if (!timed) in acquire()
|
| /libcore/ojluni/annotations/hiddenapi/java/util/concurrent/ |
| D | FutureTask.java | 105 private int awaitDone(boolean timed, long nanos) throws java.lang.InterruptedException { in awaitDone() argument
|