| /dalvik/libcore/concurrent/src/test/java/tests/api/java/util/concurrent/ |
| SystemTest.java | 30 * Nanos between readings of millis is no longer than millis (plus
44 long nanos = n2 - n1; local
45 assertTrue(nanos >= 0);
46 long nanosAsMillis = nanos / 1000000;
55 * Millis between readings of nanos is less than nanos, adjusting
69 long nanos = n2 - n1; local
71 assertTrue(nanos >= 0);
72 long nanosAsMillis = nanos / 1000000;
|
| /dalvik/libcore/concurrent/src/main/java/java/util/concurrent/ |
| AbstractExecutorService.java | 63 boolean timed, long nanos)
103 f = ecs.poll(nanos, TimeUnit.NANOSECONDS);
107 nanos -= now - lastTime;
188 long nanos = unit.toNanos(timeout); local
203 nanos -= now - lastTime;
205 if (nanos <= 0)
211 if (nanos <= 0)
214 f.get(nanos, TimeUnit.NANOSECONDS);
221 nanos -= now - lastTime;
|
| DelayQueue.java | 217 long nanos = unit.toNanos(timeout); local
224 if (nanos <= 0)
227 nanos = available.awaitNanos(nanos);
232 if (nanos <= 0)
234 if (nanos < delay || leader != null)
235 nanos = available.awaitNanos(nanos);
241 nanos -= delay - timeLeft;
|
| SynchronousQueue.java | 145 * @param nanos the timeout, in nanoseconds
151 abstract Object transfer(Object e, boolean timed, long nanos);
289 Object transfer(Object e, boolean timed, long nanos) {
317 if (timed && nanos <= 0) { // can't wait
323 SNode m = awaitFulfill(s, timed, nanos);
371 * @param nanos timeout value
374 SNode awaitFulfill(SNode s, boolean timed, long nanos) {
410 nanos -= now - lastTime;
412 if (nanos <= 0) {
423 else if (nanos > spinForTimeoutThreshold
[all...] |
| ArrayBlockingQueue.java | 274 long nanos = unit.toNanos(timeout); local
283 if (nanos <= 0)
286 nanos = notFull.awaitNanos(nanos);
329 long nanos = unit.toNanos(timeout); local
338 if (nanos <= 0)
341 nanos = notEmpty.awaitNanos(nanos);
|
| LinkedBlockingQueue.java | 284 long nanos = unit.toNanos(timeout); local
298 if (nanos <= 0)
301 nanos = notFull.awaitNanos(nanos);
380 long nanos = unit.toNanos(timeout); local
393 if (nanos <= 0)
396 nanos = notEmpty.awaitNanos(nanos);
|
| CyclicBarrier.java | 162 private int dowait(boolean timed, long nanos)
199 else if (nanos > 0L)
200 nanos = trip.awaitNanos(nanos);
219 if (timed && nanos <= 0L) {
|
| ScheduledThreadPoolExecutor.java | 964 long nanos = unit.toNanos(timeout); local
[all...] |
| Exchanger.java | 305 * @param nanos if timed, the maximum wait time
308 private Object doExchange(Object item, boolean timed, long nanos) {
329 return timed? awaitNanos(me, slot, nanos): await(me, slot);
484 * @param nanos the wait time
487 private Object awaitNanos(Node node, Slot slot, long nanos) {
499 nanos -= now - lastTime;
501 if (nanos > 0) {
509 LockSupport.parkNanos(nanos);
|
| PriorityBlockingQueue.java | 234 long nanos = unit.toNanos(timeout); local
242 if (nanos <= 0)
245 nanos = notEmpty.awaitNanos(nanos);
|
| ThreadPoolExecutor.java | 1382 long nanos = unit.toNanos(timeout); local
[all...] |
| /dalvik/libcore/luni-kernel/src/main/java/java/lang/ |
| LangAccessImpl.java | 47 public void parkFor(long nanos) {
48 Thread.currentThread().parkFor(nanos);
|
| Thread.java | [all...] |
| Object.java | 349 * @param nanos
353 * if {@code millis < 0}, {@code nanos < 0} or {@code nanos >
367 public final native void wait(long millis, int nanos) throws InterruptedException;
|
| /frameworks/base/tools/preload/ |
| Operation.java | 110 private static int nanosToMicros(long nanos) {
111 long micros = nanos / 1000;
114 throw new RuntimeException("Integer overflow: " + nanos);
|
| /dalvik/libcore/concurrent/src/main/java/java/util/concurrent/locks/ |
| LockSupport.java | 161 * @param nanos the maximum number of nanoseconds to wait
163 public static void parkNanos(long nanos) {
164 if (nanos > 0)
165 unsafe.park(false, nanos);
|
| /dalvik/libcore/luni-kernel/src/main/java/org/apache/harmony/kernel/vm/ |
| LangAccess.java | 106 * @param nanos number of nanoseconds to park for or <code>0</code>
108 * @throws IllegalArgumentException thrown if <code>nanos < 0</code>
110 public abstract void parkFor(long nanos);
|
| /external/guava/src/com/google/common/util/concurrent/ |
| Executors.java | 302 long nanos = unit.toNanos(timeout); local
308 } else if (nanos <= 0) {
311 nanos = termination.awaitNanos(nanos);
|
| AbstractFuture.java | 216 V get(long nanos) throws TimeoutException, CancellationException,
220 if (!tryAcquireSharedNanos(-1, nanos)) {
|
| /dalvik/libcore/sql/src/main/java/java/sql/ |
| Timestamp.java | 51 private int nanos; field in class:Timestamp
89 nanos = theNano;
276 return nanos;
290 theTime = theTime + (nanos / 1000000);
308 nanos = n;
370 if (nanos == 0) {
373 format(nanos, 9, sb);
486 * We must adjust for the cases where the nanos String was not 9
|
| /dalvik/vm/ |
| Sync.h | 101 s8 timeout, s4 nanos, bool interruptShouldThrow);
|
| /dalvik/libcore/sql/src/test/java/org/apache/harmony/sql/tests/java/sql/ |
| TimestampTest.java | 419 assertEquals("Wrong result for nanos test", 231000000,
425 assertEquals("Wrong result for nanos test", 231987654,
431 assertEquals("Wrong result for nanos test", 0,
437 assertEquals("Wrong result for nanos test", 309000000,
443 assertEquals("Wrong result for nanos test", 0,
574 // Also check that these Timestamps with detailed nanos values
|
| /dalvik/libcore/suncompat/src/main/java/sun/misc/ |
| Unsafe.java | 311 * @param time the (absolute millis or relative nanos) time value
|
| /frameworks/base/tests/CoreTests/android/core/ |
| MonitorTest.java | 92 /* The legal range of nanos is 0-999999. */
|
