| /libcore/ojluni/src/main/java/java/util/concurrent/locks/ |
| D | LockSupport.java | 272 public static void parkUntil(Object blocker, long deadline) { in parkUntil() argument
275 U.park(true, deadline); in parkUntil()
390 public static void parkUntil(long deadline) { in parkUntil() argument
391 U.park(true, deadline); in parkUntil()
|
| D | StampedLock.java | 493 long next, deadline; in tryWriteLock() local
498 if ((deadline = System.nanoTime() + nanos) == 0L) in tryWriteLock()
499 deadline = 1L; in tryWriteLock()
500 if ((next = acquireWrite(true, deadline)) != INTERRUPTED) in tryWriteLock()
578 long s, m, next, deadline; in tryReadLock() local
591 if ((deadline = System.nanoTime() + nanos) == 0L) in tryReadLock()
592 deadline = 1L; in tryReadLock()
593 if ((next = acquireRead(true, deadline)) != INTERRUPTED) in tryReadLock()
1233 private long acquireWrite(boolean interruptible, long deadline) { in acquireWrite() argument
1310 if (deadline == 0L) in acquireWrite()
[all …]
|
| D | AbstractQueuedLongSynchronizer.java | 483 final long deadline = System.nanoTime() + nanosTimeout; in doAcquireNanos() local
493 nanosTimeout = deadline - System.nanoTime(); in doAcquireNanos()
579 final long deadline = System.nanoTime() + nanosTimeout; in doAcquireSharedNanos() local
592 nanosTimeout = deadline - System.nanoTime(); in doAcquireSharedNanos()
1634 final long deadline = System.nanoTime() + nanosTimeout; in awaitNanos() local
1648 nanosTimeout = deadline - System.nanoTime(); in awaitNanos()
1656 long remaining = deadline - System.nanoTime(); // avoid overflow in awaitNanos()
1674 public final boolean awaitUntil(Date deadline) in awaitUntil() argument
1676 long abstime = deadline.getTime(); in awaitUntil()
1722 final long deadline = System.nanoTime() + nanosTimeout; in await() local
[all …]
|
| D | AbstractQueuedSynchronizer.java | 963 final long deadline = System.nanoTime() + nanosTimeout; in doAcquireNanos() local
973 nanosTimeout = deadline - System.nanoTime(); in doAcquireNanos()
1059 final long deadline = System.nanoTime() + nanosTimeout; in doAcquireSharedNanos() local
1072 nanosTimeout = deadline - System.nanoTime(); in doAcquireSharedNanos()
2112 final long deadline = System.nanoTime() + nanosTimeout; in awaitNanos() local
2126 nanosTimeout = deadline - System.nanoTime(); in awaitNanos()
2134 long remaining = deadline - System.nanoTime(); // avoid overflow in awaitNanos()
2152 public final boolean awaitUntil(Date deadline) in awaitUntil() argument
2154 long abstime = deadline.getTime(); in awaitUntil()
2200 final long deadline = System.nanoTime() + nanosTimeout; in await() local
[all …]
|
| D | Condition.java | 453 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()
264 final long deadline = System.nanoTime() + nanos; in invokeAll() local
276 if (((i == 0) ? nanos : deadline - System.nanoTime()) <= 0L) in invokeAll()
284 try { f.get(deadline - System.nanoTime(), NANOSECONDS); } in invokeAll()
|
| D | SynchronousQueue.java | 435 final long deadline = timed ? System.nanoTime() + nanos : 0L; in awaitFulfill() local
447 nanos = deadline - System.nanoTime(); in awaitFulfill()
735 final long deadline = timed ? System.nanoTime() + nanos : 0L; in awaitFulfill() local
747 nanos = deadline - System.nanoTime(); in awaitFulfill()
|
| D | Phaser.java | 1087 final long deadline; field in Phaser.QNode
1098 this.deadline = timed ? System.nanoTime() + nanos : 0L; in QNode()
1116 (nanos <= 0L || (nanos = deadline - System.nanoTime()) <= 0L)) { in isReleasable()
|
| D | ForkJoinTask.java | 1039 long deadline = (d == 0L) ? 1L : d; // avoid 0 in get() local
1043 s = wt.pool.awaitJoin(wt.workQueue, this, deadline); in get()
1052 (ns = deadline - System.nanoTime()) > 0L) { in get()
|
| D | CompletableFuture.java | 1741 final long deadline; // non-zero if timed field in CompletableFuture.Signaller
1746 Signaller(boolean interruptible, long nanos, long deadline) { in Signaller() argument
1750 this.deadline = deadline; in Signaller()
1764 (deadline != 0L && in isReleasable()
1766 (nanos = deadline - System.nanoTime()) <= 0L)) || in isReleasable()
1771 if (deadline == 0L) in block()
1828 long deadline = (d == 0L) ? 1L : d; // avoid 0 in timedGet() local
1834 q = new Signaller(true, nanos, deadline); in timedGet()
|
| D | ForkJoinPool.java | 1683 final int awaitJoin(WorkQueue w, ForkJoinTask<?> task, long deadline) {
1724 if (deadline == 0L)
1726 else if ((ns = deadline - System.nanoTime()) <= 0L)
2947 long deadline = System.nanoTime() + nanos;
2956 nanos = deadline - System.nanoTime();
|
| D | SubmissionPublisher.java | 1432 long deadline = timed ? System.nanoTime() + nanos : 0L; in block() local
1439 else if (timed && (nanos = deadline - System.nanoTime()) <= 0L) in block()
|
| D | LinkedTransferQueue.java | 704 final long deadline = timed ? System.nanoTime() + nanos : 0L; in awaitMatch() local
738 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
|