Home
last modified time | relevance | path

Searched refs:nanos (Results 1 – 21 of 21) sorted by relevance

/libcore/luni/src/test/java/tests/api/java/util/concurrent/
DSystemTest.java39 long nanos = n2 - n1; in testNanoTime1() local
40 assertTrue(nanos >= 0); in testNanoTime1()
41 long nanosAsMillis = nanos / 1000000; in testNanoTime1()
59 long nanos = n2 - n1; in testNanoTime2() local
61 assertTrue(nanos >= 0); in testNanoTime2()
62 long nanosAsMillis = nanos / 1000000; in testNanoTime2()
DAbstractQueuedSynchronizerTest.java362 long nanos = MILLISECONDS.toNanos(SHORT_DELAY_MS); in testAcquireNanos_Timeout()
363 assertFalse(sync.tryAcquireNanos(1, nanos)); in testAcquireNanos_Timeout()
956 long nanos = MILLISECONDS.toNanos(MEDIUM_DELAY_MS); in testAsquireSharedTimed()
957 assertTrue(l.tryAcquireSharedNanos(0, nanos)); in testAsquireSharedTimed()
994 long nanos = MILLISECONDS.toNanos(SMALL_DELAY_MS); in testAcquireSharedNanos_InterruptedException()
995 l.tryAcquireSharedNanos(0, nanos); in testAcquireSharedNanos_InterruptedException()
1013 long nanos = MILLISECONDS.toNanos(SMALL_DELAY_MS); in testAcquireSharedNanos_Timeout()
1014 assertFalse(l.tryAcquireSharedNanos(0, nanos)); in testAcquireSharedNanos_Timeout()
DAbstractQueuedLongSynchronizerTest.java365 long nanos = MILLISECONDS.toNanos(SHORT_DELAY_MS); in testAcquireNanos_Timeout()
366 assertFalse(sync.tryAcquireNanos(1, nanos)); in testAcquireNanos_Timeout()
958 long nanos = MILLISECONDS.toNanos(MEDIUM_DELAY_MS); in testAsquireSharedTimed()
959 assertTrue(l.tryAcquireSharedNanos(0, nanos)); in testAsquireSharedTimed()
996 long nanos = MILLISECONDS.toNanos(SMALL_DELAY_MS); in testAcquireSharedNanos_InterruptedException()
997 l.tryAcquireSharedNanos(0, nanos); in testAcquireSharedNanos_InterruptedException()
1015 long nanos = MILLISECONDS.toNanos(SMALL_DELAY_MS); in testAcquireSharedNanos_Timeout()
1016 assertFalse(l.tryAcquireSharedNanos(0, nanos)); in testAcquireSharedNanos_Timeout()
DThreadPoolExecutorSubclassTest.java102 long nanos = unit.toNanos(timeout); in get() local
107 if (nanos < 0) in get()
109 nanos = cond.awaitNanos(nanos); in get()
/libcore/luni/src/main/java/java/util/concurrent/locks/
DLockSupport.java193 public static void parkNanos(Object blocker, long nanos) { in parkNanos() argument
194 if (nanos > 0) { in parkNanos()
197 unsafe.park(false, nanos); in parkNanos()
314 public static void parkNanos(long nanos) { in parkNanos() argument
315 if (nanos > 0) in parkNanos()
316 unsafe.park(false, nanos); in parkNanos()
/libcore/luni/src/main/java/java/util/concurrent/
DCyclicBarrier.java164 private int dowait(boolean timed, long nanos) in dowait() argument
201 else if (nanos > 0L) in dowait()
202 nanos = trip.awaitNanos(nanos); in dowait()
221 if (timed && nanos <= 0L) { in dowait()
DAbstractExecutorService.java115 boolean timed, long nanos) in doInvokeAny() argument
155 f = ecs.poll(nanos, TimeUnit.NANOSECONDS); in doInvokeAny()
159 nanos -= now - lastTime; in doInvokeAny()
240 long nanos = unit.toNanos(timeout); in invokeAll() local
255 nanos -= now - lastTime; in invokeAll()
257 if (nanos <= 0) in invokeAll()
263 if (nanos <= 0) in invokeAll()
266 f.get(nanos, TimeUnit.NANOSECONDS); in invokeAll()
273 nanos -= now - lastTime; in invokeAll()
DDelayQueue.java224 long nanos = unit.toNanos(timeout); in poll() local
231 if (nanos <= 0) in poll()
234 nanos = available.awaitNanos(nanos); in poll()
239 if (nanos <= 0) in poll()
241 if (nanos < delay || leader != null) in poll()
242 nanos = available.awaitNanos(nanos); in poll()
248 nanos -= delay - timeLeft; in poll()
DSynchronousQueue.java156 abstract Object transfer(Object e, boolean timed, long nanos); in transfer() argument
294 Object transfer(Object e, boolean timed, long nanos) { in transfer() argument
322 if (timed && nanos <= 0) { // can't wait in transfer()
328 SNode m = awaitFulfill(s, timed, nanos); in transfer()
379 SNode awaitFulfill(SNode s, boolean timed, long nanos) { in awaitFulfill() argument
415 nanos -= now - lastTime; in awaitFulfill()
417 if (nanos <= 0) { in awaitFulfill()
428 else if (nanos > spinForTimeoutThreshold) in awaitFulfill()
429 LockSupport.parkNanos(this, nanos); in awaitFulfill()
599 Object transfer(Object e, boolean timed, long nanos) { in transfer() argument
[all …]
DLinkedBlockingDeque.java375 long nanos = unit.toNanos(timeout); in offerFirst() local
380 if (nanos <= 0) in offerFirst()
382 nanos = notFull.awaitNanos(nanos); in offerFirst()
397 long nanos = unit.toNanos(timeout); in offerLast() local
402 if (nanos <= 0) in offerLast()
404 nanos = notFull.awaitNanos(nanos); in offerLast()
478 long nanos = unit.toNanos(timeout); in pollFirst() local
484 if (nanos <= 0) in pollFirst()
486 nanos = notEmpty.awaitNanos(nanos); in pollFirst()
496 long nanos = unit.toNanos(timeout); in pollLast() local
[all …]
DExchanger.java310 private Object doExchange(Object item, boolean timed, long nanos) { in doExchange() argument
331 return timed? awaitNanos(me, slot, nanos): await(me, slot); in doExchange()
489 private Object awaitNanos(Node node, Slot slot, long nanos) { in awaitNanos() argument
501 nanos -= now - lastTime; in awaitNanos()
503 if (nanos > 0) { in awaitNanos()
511 LockSupport.parkNanos(node, nanos); in awaitNanos()
DArrayBlockingQueue.java280 long nanos = unit.toNanos(timeout); in offer() local
289 if (nanos <= 0) in offer()
292 nanos = notFull.awaitNanos(nanos); in offer()
335 long nanos = unit.toNanos(timeout); in poll() local
344 if (nanos <= 0) in poll()
347 nanos = notEmpty.awaitNanos(nanos); in poll()
DLinkedBlockingQueue.java345 long nanos = unit.toNanos(timeout); in offer() local
352 if (nanos <= 0) in offer()
354 nanos = notFull.awaitNanos(nanos); in offer()
428 long nanos = unit.toNanos(timeout); in poll() local
434 if (nanos <= 0) in poll()
436 nanos = notEmpty.awaitNanos(nanos); in poll()
DPriorityBlockingQueue.java242 long nanos = unit.toNanos(timeout); in poll() local
250 if (nanos <= 0) in poll()
253 nanos = notEmpty.awaitNanos(nanos); in poll()
DScheduledThreadPoolExecutor.java1078 long nanos = unit.toNanos(timeout); in poll() local
1085 if (nanos <= 0) in poll()
1088 nanos = available.awaitNanos(nanos); in poll()
1093 if (nanos <= 0) in poll()
1095 if (nanos < delay || leader != null) in poll()
1096 nanos = available.awaitNanos(nanos); in poll()
1102 nanos -= delay - timeLeft; in poll()
DThreadPoolExecutor.java1402 long nanos = unit.toNanos(timeout); in awaitTermination() local
1409 if (nanos <= 0) in awaitTermination()
1411 nanos = termination.awaitNanos(nanos); in awaitTermination()
/libcore/luni/src/main/java/java/sql/
DTimestamp.java49 private int nanos; field in Timestamp
87 nanos = theNano; in Timestamp()
274 return nanos; in getNanos()
288 theTime = theTime + (nanos / 1000000); in getTime()
305 nanos = n; in setNanos()
367 if (nanos == 0) { in toString()
370 format(nanos, 9, sb); in toString()
/libcore/luni/src/main/java/java/lang/
DThread.java946 public final void join(long millis, int nanos) throws InterruptedException { in join() argument
947 if (millis < 0 || nanos < 0 || nanos >= NANOS_PER_MILLI) { in join()
952 boolean overflow = millis >= (Long.MAX_VALUE - nanos) / NANOS_PER_MILLI; in join()
953 boolean forever = (millis | nanos) == 0; in join()
970 long nanosToWait = millis * NANOS_PER_MILLI + nanos; in join()
975 t.wait(millis, nanos); in join()
985 nanos = (int) (nanosRemaining - millis * NANOS_PER_MILLI); in join()
1212 public static void sleep(long millis, int nanos) throws InterruptedException { in sleep() argument
1213 VMThread.sleep(millis, nanos); in sleep()
1404 /*package*/ void parkFor(long nanos) { in parkFor() argument
[all …]
DLangAccessImpl.java47 public void parkFor(long nanos) { in parkFor() argument
48 Thread.currentThread().parkFor(nanos); in parkFor()
DObject.java435 public final native void wait(long millis, int nanos) throws InterruptedException; in wait() argument
/libcore/luni/src/main/java/org/apache/harmony/kernel/vm/
DLangAccess.java110 public abstract void parkFor(long nanos); in parkFor() argument