| /libcore/ojluni/src/main/java/java/util/concurrent/locks/ |
| D | LockSupport.java | 290 public static void parkUntil(Object blocker, long deadline) { in parkUntil() argument
293 U.park(true, deadline); in parkUntil()
409 public static void parkUntil(long deadline) { in parkUntil() argument
410 U.park(true, deadline); in parkUntil()
|
| D | Condition.java | 453 boolean awaitUntil(Date deadline) throws InterruptedException; in awaitUntil() argument
|
| D | AbstractQueuedSynchronizer.java | 1664 long deadline = System.nanoTime() + nanos; in awaitNanos() local
1668 (nanos = deadline - System.nanoTime()) <= 0L) { in awaitNanos()
1682 long remaining = deadline - System.nanoTime(); // avoid overflow in awaitNanos()
1700 public final boolean awaitUntil(Date deadline) in awaitUntil() argument
1702 long abstime = deadline.getTime(); in awaitUntil()
1749 long deadline = System.nanoTime() + nanos; in await() local
1753 (nanos = deadline - System.nanoTime()) <= 0L) { in await()
|
| D | AbstractQueuedLongSynchronizer.java | 1298 long deadline = System.nanoTime() + nanos; in awaitNanos() local
1302 (nanos = deadline - System.nanoTime()) <= 0L) { in awaitNanos()
1316 long remaining = deadline - System.nanoTime(); // avoid overflow in awaitNanos()
1334 public final boolean awaitUntil(Date deadline) in awaitUntil() argument
1336 long abstime = deadline.getTime(); in awaitUntil()
1383 long deadline = System.nanoTime() + nanos; in await() local
1387 (nanos = deadline - System.nanoTime()) <= 0L) { in await()
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | AbstractExecutorService.java | 174 final long deadline = timed ? System.nanoTime() + nanos : 0L; in doInvokeAny() local
196 nanos = deadline - System.nanoTime(); in doInvokeAny()
269 final long deadline = System.nanoTime() + nanos; in invokeAll() local
281 if (((i == 0) ? nanos : deadline - System.nanoTime()) <= 0L) in invokeAll()
289 try { f.get(deadline - System.nanoTime(), NANOSECONDS); } in invokeAll()
|
| D | Phaser.java | 1093 final long deadline; field in Phaser.QNode
1104 this.deadline = timed ? System.nanoTime() + nanos : 0L; in QNode()
1122 (nanos <= 0L || (nanos = deadline - System.nanoTime()) <= 0L)) { in isReleasable()
|
| D | ForkJoinTask.java | 424 long deadline = 0L; in awaitDone() local
428 else if ((deadline = nanos + System.nanoTime()) == 0L) in awaitDone()
429 deadline = 1L; in awaitDone()
466 if (deadline != 0L) { in awaitDone()
467 if ((ns = deadline - System.nanoTime()) <= 0L) in awaitDone()
|
| D | SynchronousQueue.java | 372 long deadline = timed ? System.nanoTime() + nanos : 0L; in transfer() local
378 (nanos = deadline - System.nanoTime()) <= 0) || in transfer()
671 long deadline = timed ? System.nanoTime() + nanos : 0L; in transfer() local
677 (nanos = deadline - System.nanoTime()) <= 0) || in transfer()
|
| D | ForkJoinPool.java | 1687 long deadline = 0L; // nonzero if possibly quiescent
1693 if ((deadline = System.currentTimeMillis() + keepAlive) == 0L)
1694 deadline = 1L; // avoid zero
1726 else if (deadline == 0L)
1728 else if (deadline - System.currentTimeMillis() > TIMEOUT_SLOP)
1729 LockSupport.parkUntil(deadline);
1736 else if ((deadline += keepAlive) == 0L)
1737 deadline = 1L; // not at head; restart timer
|
| D | CompletableFuture.java | 1809 final long deadline; // non-zero if timed field in CompletableFuture.Signaller
1814 Signaller(boolean interruptible, long nanos, long deadline) { in Signaller() argument
1818 this.deadline = deadline; in Signaller()
1832 (deadline != 0L && in isReleasable()
1834 (nanos = deadline - System.nanoTime()) <= 0L)) || in isReleasable()
1839 if (deadline == 0L) in block()
1895 long deadline = (d == 0L) ? 1L : d; // avoid 0 in timedGet() local
1907 q = new Signaller(true, nanos, deadline); in timedGet()
|
| D | SubmissionPublisher.java | 1479 long deadline = timed ? System.nanoTime() + nanos : 0L; in block() local
1486 else if (timed && (nanos = deadline - System.nanoTime()) <= 0L) in block()
|
| D | LinkedTransferQueue.java | 638 final long deadline = timed ? System.nanoTime() + nanos : 0L; in awaitMatch() local
674 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
|