| /libcore/ojluni/src/main/java/java/util/concurrent/locks/ |
| D | LockSupport.java | 268 public static void parkUntil(Object blocker, long deadline) { in parkUntil() argument
271 U.park(true, deadline); in parkUntil()
386 public static void parkUntil(long deadline) { in parkUntil() argument
387 U.park(true, deadline); in parkUntil()
|
| D | StampedLock.java | 383 long next, deadline; in tryWriteLock() local
388 if ((deadline = System.nanoTime() + nanos) == 0L) in tryWriteLock()
389 deadline = 1L; in tryWriteLock()
390 if ((next = acquireWrite(true, deadline)) != INTERRUPTED) in tryWriteLock()
462 long s, m, next, deadline; in tryReadLock() local
475 if ((deadline = System.nanoTime() + nanos) == 0L) in tryReadLock()
476 deadline = 1L; in tryReadLock()
477 if ((next = acquireRead(true, deadline)) != INTERRUPTED) in tryReadLock()
1033 private long acquireWrite(boolean interruptible, long deadline) { in acquireWrite() argument
1110 if (deadline == 0L) in acquireWrite()
[all …]
|
| D | AbstractQueuedLongSynchronizer.java | 479 final long deadline = System.nanoTime() + nanosTimeout; in doAcquireNanos() local
489 nanosTimeout = deadline - System.nanoTime(); in doAcquireNanos()
575 final long deadline = System.nanoTime() + nanosTimeout; in doAcquireSharedNanos() local
588 nanosTimeout = deadline - System.nanoTime(); in doAcquireSharedNanos()
1626 final long deadline = System.nanoTime() + nanosTimeout; in awaitNanos() local
1640 nanosTimeout = deadline - System.nanoTime(); in awaitNanos()
1648 long remaining = deadline - System.nanoTime(); // avoid overflow in awaitNanos()
1666 public final boolean awaitUntil(Date deadline) in awaitUntil() argument
1668 long abstime = deadline.getTime(); in awaitUntil()
1714 final long deadline = System.nanoTime() + nanosTimeout; in await() local
[all …]
|
| D | AbstractQueuedSynchronizer.java | 947 final long deadline = System.nanoTime() + nanosTimeout; in doAcquireNanos() local
957 nanosTimeout = deadline - System.nanoTime(); in doAcquireNanos()
1043 final long deadline = System.nanoTime() + nanosTimeout; in doAcquireSharedNanos() local
1056 nanosTimeout = deadline - System.nanoTime(); in doAcquireSharedNanos()
2098 final long deadline = System.nanoTime() + nanosTimeout; in awaitNanos() local
2112 nanosTimeout = deadline - System.nanoTime(); in awaitNanos()
2120 long remaining = deadline - System.nanoTime(); // avoid overflow in awaitNanos()
2138 public final boolean awaitUntil(Date deadline) in awaitUntil() argument
2140 long abstime = deadline.getTime(); in awaitUntil()
2186 final long deadline = System.nanoTime() + nanosTimeout; in await() local
[all …]
|
| D | Condition.java | 451 boolean awaitUntil(Date deadline) throws InterruptedException; in awaitUntil() argument
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | AbstractExecutorService.java | 169 final long deadline = timed ? System.nanoTime() + nanos : 0L; in doInvokeAny() local
191 nanos = deadline - System.nanoTime(); in doInvokeAny()
265 final long deadline = System.nanoTime() + nanos; in invokeAll() local
277 if (((i == 0) ? nanos : deadline - System.nanoTime()) <= 0L) in invokeAll()
285 try { f.get(deadline - System.nanoTime(), NANOSECONDS); } in invokeAll()
|
| D | SynchronousQueue.java | 436 final long deadline = timed ? System.nanoTime() + nanos : 0L; in awaitFulfill() local
448 nanos = deadline - System.nanoTime(); in awaitFulfill()
737 final long deadline = timed ? System.nanoTime() + nanos : 0L; in awaitFulfill() local
749 nanos = deadline - System.nanoTime(); in awaitFulfill()
|
| D | Phaser.java | 1091 final long deadline; field in Phaser.QNode
1102 this.deadline = timed ? System.nanoTime() + nanos : 0L; in QNode()
1120 (nanos <= 0L || (nanos = deadline - System.nanoTime()) <= 0L)) { in isReleasable()
|
| D | ForkJoinTask.java | 1023 long deadline = (d == 0L) ? 1L : d; // avoid 0 in get() local
1027 s = wt.pool.awaitJoin(wt.workQueue, this, deadline); in get()
1036 (ns = deadline - System.nanoTime()) > 0L) { in get()
|
| D | ForkJoinPool.java | 1835 long deadline = (((scale <= 0) ? 1 : scale) * IDLE_TIMEOUT_MS + in timedAwaitWork() local
1842 LockSupport.parkUntil(this, deadline); in timedAwaitWork()
1848 deadline - System.currentTimeMillis() <= TIMEOUT_SLOP_MS) { in timedAwaitWork()
2226 final int awaitJoin(WorkQueue w, ForkJoinTask<?> task, long deadline) { in awaitJoin() argument
2242 if (deadline == 0L) in awaitJoin()
2244 else if ((ns = deadline - System.nanoTime()) <= 0L) in awaitJoin()
3256 long deadline = System.nanoTime() + nanos; in awaitTermination() local
3265 nanos = deadline - System.nanoTime(); in awaitTermination()
|
| D | CompletableFuture.java | 1692 final long deadline; // non-zero if timed field in CompletableFuture.Signaller
1697 Signaller(boolean interruptible, long nanos, long deadline) { in Signaller() argument
1701 this.deadline = deadline; in Signaller()
1715 (deadline != 0L && in isReleasable()
1717 (nanos = deadline - System.nanoTime()) <= 0L)) || in isReleasable()
1722 if (deadline == 0L) in block()
1783 long deadline = (d == 0L) ? 1L : d; // avoid 0 in timedGet() local
1789 q = new Signaller(true, nanos, deadline); in timedGet()
|
| D | LinkedTransferQueue.java | 694 final long deadline = timed ? System.nanoTime() + nanos : 0L; in awaitMatch() local
725 nanos = deadline - System.nanoTime(); in awaitMatch()
|
| /libcore/ojluni/src/test/java/util/concurrent/tck/ |
| D | LockSupportTest.java | 81 LockSupport.parkUntil(deadline(millis)); in parkUntil()
99 LockSupport.parkUntil(theBlocker(), deadline(millis)); in parkUntilBlocker()
113 long deadline(long millis) { in deadline() method in LockSupportTest.ParkMethod
|
| /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
|