| /libcore/luni/src/main/java/java/util/concurrent/locks/ |
| D | LockSupport.java | 239 public static void parkUntil(Object blocker, long deadline) { in parkUntil() argument
242 U.park(true, deadline); in parkUntil()
357 public static void parkUntil(long deadline) { in parkUntil() argument
358 U.park(true, deadline); in parkUntil()
|
| D | StampedLock.java | 354 long next, deadline; in tryWriteLock() local
359 if ((deadline = System.nanoTime() + nanos) == 0L) in tryWriteLock()
360 deadline = 1L; in tryWriteLock()
361 if ((next = acquireWrite(true, deadline)) != INTERRUPTED) in tryWriteLock()
433 long s, m, next, deadline; in tryReadLock() local
446 if ((deadline = System.nanoTime() + nanos) == 0L) in tryReadLock()
447 deadline = 1L; in tryReadLock()
448 if ((next = acquireRead(true, deadline)) != INTERRUPTED) in tryReadLock()
1004 private long acquireWrite(boolean interruptible, long deadline) { in acquireWrite() argument
1081 if (deadline == 0L) in acquireWrite()
[all …]
|
| D | Condition.java | 422 boolean awaitUntil(Date deadline) throws InterruptedException; in awaitUntil() argument
|
| D | AbstractQueuedLongSynchronizer.java | 450 final long deadline = System.nanoTime() + nanosTimeout; in doAcquireNanos() local
460 nanosTimeout = deadline - System.nanoTime(); in doAcquireNanos()
546 final long deadline = System.nanoTime() + nanosTimeout; in doAcquireSharedNanos() local
559 nanosTimeout = deadline - System.nanoTime(); in doAcquireSharedNanos()
1597 final long deadline = System.nanoTime() + nanosTimeout; in awaitNanos() local
1611 nanosTimeout = deadline - System.nanoTime(); in awaitNanos()
1619 long remaining = deadline - System.nanoTime(); // avoid overflow in awaitNanos()
1637 public final boolean awaitUntil(Date deadline) in awaitUntil() argument
1639 long abstime = deadline.getTime(); in awaitUntil()
1685 final long deadline = System.nanoTime() + nanosTimeout; in await() local
[all …]
|
| D | AbstractQueuedSynchronizer.java | 918 final long deadline = System.nanoTime() + nanosTimeout; in doAcquireNanos() local
928 nanosTimeout = deadline - System.nanoTime(); in doAcquireNanos()
1014 final long deadline = System.nanoTime() + nanosTimeout; in doAcquireSharedNanos() local
1027 nanosTimeout = deadline - System.nanoTime(); in doAcquireSharedNanos()
2066 final long deadline = System.nanoTime() + nanosTimeout; in awaitNanos() local
2080 nanosTimeout = deadline - System.nanoTime(); in awaitNanos()
2088 long remaining = deadline - System.nanoTime(); // avoid overflow in awaitNanos()
2106 public final boolean awaitUntil(Date deadline) in awaitUntil() argument
2108 long abstime = deadline.getTime(); in awaitUntil()
2154 final long deadline = System.nanoTime() + nanosTimeout; in await() local
[all …]
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| D | AbstractExecutorService.java | 140 final long deadline = timed ? System.nanoTime() + nanos : 0L; in doInvokeAny() local
162 nanos = deadline - System.nanoTime(); in doInvokeAny()
236 final long deadline = System.nanoTime() + nanos; in invokeAll() local
248 if (((i == 0) ? nanos : deadline - System.nanoTime()) <= 0L) in invokeAll()
256 try { f.get(deadline - System.nanoTime(), NANOSECONDS); } in invokeAll()
|
| D | SynchronousQueue.java | 407 final long deadline = timed ? System.nanoTime() + nanos : 0L; in awaitFulfill() local
419 nanos = deadline - System.nanoTime(); in awaitFulfill()
708 final long deadline = timed ? System.nanoTime() + nanos : 0L; in awaitFulfill() local
720 nanos = deadline - System.nanoTime(); in awaitFulfill()
|
| D | Phaser.java | 1062 final long deadline; field in Phaser.QNode
1073 this.deadline = timed ? System.nanoTime() + nanos : 0L; in QNode()
1091 (nanos <= 0L || (nanos = deadline - System.nanoTime()) <= 0L)) { in isReleasable()
|
| D | ForkJoinTask.java | 994 long deadline = (d == 0L) ? 1L : d; // avoid 0 in get() local
998 s = wt.pool.awaitJoin(wt.workQueue, this, deadline); in get()
1007 (ns = deadline - System.nanoTime()) > 0L) { in get()
|
| D | ForkJoinPool.java | 1803 long deadline = (((scale <= 0) ? 1 : scale) * IDLE_TIMEOUT_MS + in timedAwaitWork() local
1810 LockSupport.parkUntil(this, deadline); in timedAwaitWork()
1816 deadline - System.currentTimeMillis() <= TIMEOUT_SLOP_MS) { in timedAwaitWork()
2194 final int awaitJoin(WorkQueue w, ForkJoinTask<?> task, long deadline) { in awaitJoin() argument
2210 if (deadline == 0L) in awaitJoin()
2212 else if ((ns = deadline - System.nanoTime()) <= 0L) in awaitJoin()
3224 long deadline = System.nanoTime() + nanos; in awaitTermination() local
3233 nanos = deadline - System.nanoTime(); in awaitTermination()
|
| D | CompletableFuture.java | 1661 final long deadline; // non-zero if timed field in CompletableFuture.Signaller
1666 Signaller(boolean interruptible, long nanos, long deadline) { in Signaller() argument
1670 this.deadline = deadline; in Signaller()
1684 (deadline != 0L && in isReleasable()
1686 (nanos = deadline - System.nanoTime()) <= 0L)) || in isReleasable()
1691 if (deadline == 0L) in block()
1752 long deadline = (d == 0L) ? 1L : d; // avoid 0 in timedGet() local
1758 q = new Signaller(true, nanos, deadline); in timedGet()
|
| D | LinkedTransferQueue.java | 665 final long deadline = timed ? System.nanoTime() + nanos : 0L; in awaitMatch() local
696 nanos = deadline - System.nanoTime(); in awaitMatch()
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | LockSupportTest.java | 57 LockSupport.parkUntil(deadline(millis)); in parkUntil()
75 LockSupport.parkUntil(theBlocker(), deadline(millis)); in parkUntilBlocker()
89 long deadline(long millis) { in deadline() method in LockSupportTest.ParkMethod
|