| /libcore/luni/src/main/java/java/util/concurrent/locks/ |
| H A D | LockSupport.java | 192 * @param nanos the maximum number of nanoseconds to wait
195 public static void parkNanos(Object blocker, long nanos) { argument
196 if (nanos > 0) {
199 unsafe.park(false, nanos);
318 * @param nanos the maximum number of nanoseconds to wait
320 public static void parkNanos(long nanos) { argument
321 if (nanos > 0)
322 unsafe.park(false, nanos);
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| H A D | CyclicBarrier.java | 164 private int dowait(boolean timed, long nanos) argument
201 else if (nanos > 0L)
202 nanos = trip.awaitNanos(nanos);
221 if (timed && nanos <= 0L) {
|
| H A D | AbstractExecutorService.java | 111 boolean timed, long nanos)
151 f = ecs.poll(nanos, TimeUnit.NANOSECONDS);
155 nanos -= now - lastTime;
234 long nanos = unit.toNanos(timeout);
249 nanos -= now - lastTime;
251 if (nanos <= 0)
257 if (nanos <= 0)
260 f.get(nanos, TimeUnit.NANOSECONDS);
267 nanos -= now - lastTime;
110 doInvokeAny(Collection<? extends Callable<T>> tasks, boolean timed, long nanos) argument
|
| H A D | DelayQueue.java | 221 long nanos = unit.toNanos(timeout);
228 if (nanos <= 0)
231 nanos = available.awaitNanos(nanos);
236 if (nanos <= 0)
238 if (nanos < delay || leader != null)
239 nanos = available.awaitNanos(nanos);
245 nanos -= delay - timeLeft;
|
| H A D | SynchronousQueue.java | 144 * @param nanos the timeout, in nanoseconds
150 abstract Object transfer(Object e, boolean timed, long nanos); argument
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);
377 * @param nanos timeout value
380 SNode awaitFulfill(SNode s, boolean timed, long nanos) { argument
415 nanos -= now - lastTime;
417 if (nanos <= 0) {
428 else if (nanos > spinForTimeoutThreshol
612 transfer(Object e, boolean timed, long nanos) argument
706 awaitFulfill(QNode s, Object e, boolean timed, long nanos) argument
[all...] |
| H A D | LinkedBlockingDeque.java | 378 long nanos = unit.toNanos(timeout);
383 if (nanos <= 0)
385 nanos = notFull.awaitNanos(nanos);
401 long nanos = unit.toNanos(timeout);
406 if (nanos <= 0)
408 nanos = notFull.awaitNanos(nanos);
482 long nanos = unit.toNanos(timeout);
488 if (nanos <
[all...] |
| H A D | Phaser.java | 760 long nanos = unit.toNanos(timeout);
767 QNode node = new QNode(this, phase, true, true, nanos);
1067 long nanos; field in class:Phaser.QNode
1073 boolean timed, long nanos) {
1077 this.nanos = nanos;
1097 if (nanos > 0L) {
1099 nanos -= now - lastTime;
1102 if (nanos <= 0L) {
1115 else if (nanos >
1072 QNode(Phaser phaser, int phase, boolean interruptible, boolean timed, long nanos) argument
[all...] |
| H A D | Exchanger.java | 306 * @param nanos if timed, the maximum wait time
309 private Object doExchange(Object item, boolean timed, long nanos) { argument
331 awaitNanos(me, slot, nanos) :
487 * @param nanos the wait time
490 private Object awaitNanos(Node node, Slot slot, long nanos) { argument
502 nanos -= now - lastTime;
504 if (nanos > 0) {
512 LockSupport.parkNanos(node, nanos);
|
| H A D | LinkedBlockingQueue.java | 346 long nanos = unit.toNanos(timeout);
353 if (nanos <= 0)
355 nanos = notFull.awaitNanos(nanos);
430 long nanos = unit.toNanos(timeout);
436 if (nanos <= 0)
438 nanos = notEmpty.awaitNanos(nanos);
|
| H A D | ScheduledThreadPoolExecutor.java | 1080 long nanos = unit.toNanos(timeout);
1087 if (nanos <= 0)
1090 nanos = available.awaitNanos(nanos);
1095 if (nanos <= 0)
1097 if (nanos < delay || leader != null)
1098 nanos = available.awaitNanos(nanos);
1104 nanos -= delay - timeLeft;
|
| H A D | ArrayBlockingQueue.java | 341 long nanos = unit.toNanos(timeout);
346 if (nanos <= 0)
348 nanos = notFull.awaitNanos(nanos);
380 long nanos = unit.toNanos(timeout);
385 if (nanos <= 0)
387 nanos = notEmpty.awaitNanos(nanos);
|
| H A D | FutureTask.java | 361 * @param nanos time to wait, if timed
364 private int awaitDone(boolean timed, long nanos) argument
388 if ((nanos -= (now - last)) <= 0L) {
393 LockSupport.parkNanos(this, nanos);
|
| H A D | LinkedTransferQueue.java | 572 * @param nanos timeout in nanosecs, used only if mode is TIMED
576 private E xfer(E e, boolean haveData, int how, long nanos) { argument
616 return awaitMatch(s, pred, e, (how == TIMED), nanos);
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
682 if ((w.isInterrupted() || (timed && nanos <= 0)) &&
702 if ((nanos -= now - lastTime) > 0)
703 LockSupport.parkNanos(this, nanos);
|
| H A D | ForkJoinPool.java | 1030 * @param nanos the wait time for underlying Object.wait
1032 final void timedAwaitJoin(ForkJoinTask<?> joinMe, long nanos) { argument
1042 long millis = TimeUnit.NANOSECONDS.toMillis(nanos);
1053 nanos -= now - last;
1951 long nanos = unit.toNanos(timeout);
1958 if (nanos <= 0)
1960 nanos = termination.awaitNanos(nanos);
|
| H A D | PriorityBlockingQueue.java | 513 long nanos = unit.toNanos(timeout);
518 while ( (result = dequeue()) == null && nanos > 0)
519 nanos = notEmpty.awaitNanos(nanos);
|
| H A D | ThreadPoolExecutor.java | 1390 long nanos = unit.toNanos(timeout);
1397 if (nanos <= 0)
1399 nanos = termination.awaitNanos(nanos);
|
| H A D | ForkJoinTask.java | 936 long nanos = unit.toNanos(timeout);
948 else if (status >= 0 && nanos > 0)
949 w.pool.timedAwaitJoin(this, nanos);
|
| /libcore/luni/src/main/java/java/lang/ |
| H A D | Object.java | 424 * @param nanos
428 * if {@code millis < 0}, {@code nanos < 0} or {@code nanos >
441 public final native void wait(long millis, int nanos) throws InterruptedException; argument
|
| H A D | Thread.java | 787 * @param nanos Extra nanosecond precision
793 public final void join(long millis, int nanos) throws InterruptedException { argument
794 if (millis < 0 || nanos < 0 || nanos >= NANOS_PER_MILLI) {
799 boolean overflow = millis >= (Long.MAX_VALUE - nanos) / NANOS_PER_MILLI;
800 boolean forever = (millis | nanos) == 0;
817 long nanosToWait = millis * NANOS_PER_MILLI + nanos;
822 t.wait(millis, nanos);
832 nanos = (int) (nanosRemaining - millis * NANOS_PER_MILLI);
1023 * @param nanos
1030 sleep(long millis, int nanos) argument
1211 parkFor(long nanos) argument
[all...] |
| /libcore/luni/src/main/java/java/sql/ |
| H A D | Timestamp.java | 49 private int nanos; field in class:Timestamp
87 nanos = theNano;
274 return nanos;
288 theTime = theTime + (nanos / 1000000);
305 nanos = n;
367 if (nanos == 0) {
370 format(nanos, 9, sb);
481 * We must adjust for the cases where the nanos String was not 9
|