/openjdk9/jdk/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/ |
H A D | TimeoutEvent.java | 46 private final Instant deadline; field in class:TimeoutEvent 49 deadline = Instant.now().plus(duration); 54 public Instant deadline() { method in class:TimeoutEvent 55 return deadline; 61 // if two events have the same deadline, but are not equals, then the 65 // same deadline cannot compare == 0 if they are not equals. 66 final int compareDeadline = this.deadline.compareTo(other.deadline); 71 else assert false : "Different events with same id and deadline"; 78 return "TimeoutEvent[id=" + id + ", deadline [all...] |
/openjdk9/jdk/src/java.base/share/classes/java/util/concurrent/locks/ |
H A D | Condition.java | 378 * or the specified deadline elapses. 391 * <li>The specified deadline elapses; or 410 * <p>The return value indicates whether the deadline has elapsed, 413 * boolean aMethod(Date deadline) { 420 * stillWaiting = theCondition.awaitUntil(deadline); 439 * of the specified deadline. In either case the implementation 443 * @param deadline the absolute time to wait until 444 * @return {@code false} if the deadline has elapsed upon return, else 449 boolean awaitUntil(Date deadline) throws InterruptedException; argument
|
H A D | LockSupport.java | 241 * the specified deadline, unless the permit is available. 255 * <li>The specified deadline passes; or 268 * @param deadline the absolute time, in milliseconds from the Epoch, 272 public static void parkUntil(Object blocker, long deadline) { argument 275 U.park(true, deadline); 362 * the specified deadline, unless the permit is available. 376 * <li>The specified deadline passes; or 387 * @param deadline the absolute time, in milliseconds from the Epoch, 390 public static void parkUntil(long deadline) { argument 391 U.park(true, deadline); [all...] |
H A D | StampedLock.java | 458 long next, deadline; 463 if ((deadline = System.nanoTime() + nanos) == 0L) 464 deadline = 1L; 465 if ((next = acquireWrite(true, deadline)) != INTERRUPTED) 543 long s, m, next, deadline; 556 if ((deadline = System.nanoTime() + nanos) == 0L) 557 deadline = 1L; 558 if ((next = acquireRead(true, deadline)) != INTERRUPTED) 1106 * @param deadline if nonzero, the System.nanoTime value to timeout 1110 private long acquireWrite(boolean interruptible, long deadline) { argument 1218 acquireRead(boolean interruptible, long deadline) argument [all...] |
H A D | AbstractQueuedSynchronizer.java | 948 final long deadline = System.nanoTime() + nanosTimeout; 958 nanosTimeout = deadline - System.nanoTime(); 1044 final long deadline = System.nanoTime() + nanosTimeout; 1057 nanosTimeout = deadline - System.nanoTime(); 2093 final long deadline = System.nanoTime() + nanosTimeout; 2107 nanosTimeout = deadline - System.nanoTime(); 2115 long remaining = deadline - System.nanoTime(); // avoid overflow 2133 public final boolean awaitUntil(Date deadline) argument 2135 long abstime = deadline.getTime(); 2181 final long deadline [all...] |
H A D | AbstractQueuedLongSynchronizer.java | 481 final long deadline = System.nanoTime() + nanosTimeout; 491 nanosTimeout = deadline - System.nanoTime(); 577 final long deadline = System.nanoTime() + nanosTimeout; 590 nanosTimeout = deadline - System.nanoTime(); 1628 final long deadline = System.nanoTime() + nanosTimeout; 1642 nanosTimeout = deadline - System.nanoTime(); 1650 long remaining = deadline - System.nanoTime(); // avoid overflow 1668 public final boolean awaitUntil(Date deadline) argument 1670 long abstime = deadline.getTime(); 1716 final long deadline [all...] |
/openjdk9/jdk/test/java/rmi/testlibrary/ |
H A D | ActivationLibrary.java | 56 long deadline = TestLibrary.computeDeadline(startTime, DEACTIVATE_TIME_MS); 58 while (System.currentTimeMillis() < deadline) {
|
H A D | RegistryVM.java | 143 long deadline = TestLibrary.computeDeadline(startTime, (long)START_TIMEOUT); 160 if (System.currentTimeMillis() > deadline) {
|
H A D | RMIDSelectorProvider.java | 108 long deadline = System.currentTimeMillis() + timeout; 120 if (System.currentTimeMillis() > deadline) {
|
H A D | RMID.java | 351 long deadline = TestLibrary.computeDeadline(startTime, waitTime); 391 if (System.currentTimeMillis() > deadline) {
|
H A D | JavaVM.java | 296 long deadline = TestLibrary.computeDeadline(System.currentTimeMillis(), timeout); 306 if (System.currentTimeMillis() > deadline)
|
/openjdk9/jdk/test/java/rmi/dgc/retryDirtyCalls/ |
H A D | RetryDirtyCalls.java | 112 long deadline = System.currentTimeMillis() + TIMEOUT; 117 long timeToWait = deadline - System.currentTimeMillis();
|
/openjdk9/jdk/src/java.base/share/classes/java/util/concurrent/ |
H A D | AbstractExecutorService.java | 169 final long deadline = timed ? System.nanoTime() + nanos : 0L; 191 nanos = deadline - System.nanoTime(); 265 final long deadline = System.nanoTime() + nanos; 277 if (((i == 0) ? nanos : deadline - System.nanoTime()) <= 0L) 285 try { f.get(deadline - System.nanoTime(), NANOSECONDS); }
|
H A D | Phaser.java | 1087 final long deadline; field in class:Phaser.QNode 1098 this.deadline = timed ? System.nanoTime() + nanos : 0L; 1116 (nanos <= 0L || (nanos = deadline - System.nanoTime()) <= 0L)) {
|
H A D | SynchronousQueue.java | 435 final long deadline = timed ? System.nanoTime() + nanos : 0L; 447 nanos = deadline - System.nanoTime(); 734 final long deadline = timed ? System.nanoTime() + nanos : 0L; 746 nanos = deadline - System.nanoTime();
|
H A D | CompletableFuture.java | 1765 final long deadline; // non-zero if timed field in class:CompletableFuture.Signaller 1770 Signaller(boolean interruptible, long nanos, long deadline) { argument 1774 this.deadline = deadline; 1788 (deadline != 0L && 1790 (nanos = deadline - System.nanoTime()) <= 0L)) || 1795 if (deadline == 0L) 1852 long deadline = (d == 0L) ? 1L : d; // avoid 0 1858 q = new Signaller(true, nanos, deadline);
|
/openjdk9/jdk/test/javax/management/mxbean/ |
H A D | LeakTest.java | 89 long deadline = System.currentTimeMillis() + 20*1000; 91 while (wr.get() != null && System.currentTimeMillis() < deadline) {
|
/openjdk9/jdk/test/javax/management/remote/mandatory/connection/ |
H A D | DaemonRMIExporterTest.java | 84 long deadline = System.currentTimeMillis() + 10000; 86 while (System.currentTimeMillis() < deadline) {
|
H A D | IdleTimeoutTest.java | 224 long deadline = startTime + 10000; 230 while (System.currentTimeMillis() < deadline) {
|
/openjdk9/jdk/test/java/util/concurrent/tck/ |
H A D | LockSupportTest.java | 80 LockSupport.parkUntil(deadline(millis)); 98 LockSupport.parkUntil(theBlocker(), deadline(millis)); 111 /** Returns a deadline to use with parkUntil. */ 112 long deadline(long millis) { method in class:LockSupportTest.ParkMethod
|
/openjdk9/jdk/test/java/lang/Thread/ |
H A D | ThreadStateController.java | 189 long deadline = System.currentTimeMillis() + 192 LockSupport.parkUntil(deadline);
|
/openjdk9/jdk/test/javax/management/remote/mandatory/notif/ |
H A D | NotificationEmissionTest.java | 299 long deadline = System.currentTimeMillis() + 2000; 301 System.currentTimeMillis() < deadline)
|
/openjdk9/jdk/src/java.base/windows/classes/java/lang/ |
H A D | ProcessImpl.java | 500 long deadline = System.nanoTime() + remainingNanos ; 510 remainingNanos = deadline - System.nanoTime();
|
/openjdk9/jdk/src/java.base/unix/classes/java/lang/ |
H A D | ProcessImpl.java | 507 long deadline = System.nanoTime() + remainingNanos; 514 remainingNanos = deadline - System.nanoTime();
|
/openjdk9/jdk/test/javax/management/remote/mandatory/loading/ |
H A D | MissingClassTest.java | 493 long deadline = System.currentTimeMillis() + 60000; 495 while ((remain = deadline - System.currentTimeMillis()) >= 0) {
|