Home
last modified time | relevance | path

Searched refs:delay (Results 1 – 25 of 35) sorted by relevance

12

/libcore/ojluni/src/main/java/java/util/concurrent/
DScheduledThreadPoolExecutor.java568 private long triggerTime(long delay, TimeUnit unit) { in triggerTime() argument
569 return triggerTime(unit.toNanos((delay < 0) ? 0 : delay)); in triggerTime()
575 long triggerTime(long delay) { in triggerTime() argument
577 ((delay < (Long.MAX_VALUE >> 1)) ? delay : overflowFree(delay)); in triggerTime()
587 private long overflowFree(long delay) { in overflowFree() argument
591 if (headDelay < 0 && (delay - headDelay < 0)) in overflowFree()
592 delay = Long.MAX_VALUE + headDelay; in overflowFree()
594 return delay; in overflowFree()
602 long delay, in schedule() argument
608 triggerTime(delay, unit), in schedule()
[all …]
DDelayQueue.java244 long delay = first.getDelay(NANOSECONDS); in take() local
245 if (delay <= 0L) in take()
254 available.awaitNanos(delay); in take()
293 long delay = first.getDelay(NANOSECONDS); in poll() local
294 if (delay <= 0L) in poll()
299 if (nanos < delay || leader != null) in poll()
305 long timeLeft = available.awaitNanos(delay); in poll()
306 nanos -= delay - timeLeft; in poll()
DScheduledExecutorService.java107 long delay, TimeUnit unit); in schedule() argument
123 long delay, TimeUnit unit); in schedule() argument
206 long delay, in scheduleWithFixedDelay() argument
DExecutors.java824 public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
825 return e.schedule(command, delay, unit);
827 public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) {
828 return e.schedule(callable, delay, unit);
833 …dFuture<?> scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit) {
834 return e.scheduleWithFixedDelay(command, initialDelay, delay, unit);
DCompletableFuture.java2741 whenComplete(new Canceller(Delayer.delay(new Timeout(this), in orTimeout()
2763 whenComplete(new Canceller(Delayer.delay( in completeOnTimeout()
2782 public static Executor delayedExecutor(long delay, TimeUnit unit, in delayedExecutor() argument
2786 return new DelayedExecutor(delay, unit, executor); in delayedExecutor()
2801 public static Executor delayedExecutor(long delay, TimeUnit unit) { in delayedExecutor() argument
2804 return new DelayedExecutor(delay, unit, ASYNC_POOL); in delayedExecutor()
2855 static ScheduledFuture<?> delay(Runnable command, long delay, in delay() argument
2857 return delayer.schedule(command, delay, unit); in delay()
2880 final long delay; field in CompletableFuture.DelayedExecutor
2883 DelayedExecutor(long delay, TimeUnit unit, Executor executor) { in DelayedExecutor() argument
[all …]
/libcore/ojluni/src/main/java/java/util/
DTimer.java237 public void schedule(TimerTask task, long delay) { in schedule() argument
238 if (delay < 0) in schedule()
240 sched(task, System.currentTimeMillis()+delay, 0); in schedule()
290 public void schedule(TimerTask task, long delay, long period) { in schedule() argument
291 if (delay < 0) in schedule()
295 sched(task, System.currentTimeMillis()+delay, -period); in schedule()
381 public void scheduleAtFixedRate(TimerTask task, long delay, long period) { in scheduleAtFixedRate() argument
382 if (delay < 0) in scheduleAtFixedRate()
386 sched(task, System.currentTimeMillis()+delay, period); in scheduleAtFixedRate()
/libcore/jsr166-tests/src/test/java/jsr166/
DJSR166TestCase.java838 static void delay(long millis) throws InterruptedException { in delay() method in JSR166TestCase
993 delay(millis);
1014 delay(millis);
1199 delay(millis);
1559 delay(SHORT_DELAY_MS);
1565 delay(SHORT_DELAY_MS);
1571 delay(SMALL_DELAY_MS);
1578 delay(SMALL_DELAY_MS);
1585 delay(SMALL_DELAY_MS);
1592 delay(MEDIUM_DELAY_MS);
[all …]
DScheduledExecutorSubclassTest.java217 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) { in testFixedRateSequence()
224 p.scheduleAtFixedRate(task, 0, delay, MILLISECONDS); in testFixedRateSequence()
225 final int totalDelayMillis = (cycles - 1) * delay; in testFixedRateSequence()
230 if (elapsedMillis <= cycles * delay) in testFixedRateSequence()
246 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) { in testFixedDelaySequence()
252 final int d = delay; in testFixedDelaySequence()
270 p.scheduleWithFixedDelay(task, 0, delay, MILLISECONDS); in testFixedDelaySequence()
271 final int totalDelayMillis = (cycles - 1) * delay; in testFixedDelaySequence()
DScheduledExecutorTest.java161 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) { in testFixedRateSequence()
168 p.scheduleAtFixedRate(task, 0, delay, MILLISECONDS); in testFixedRateSequence()
169 final int totalDelayMillis = (cycles - 1) * delay; in testFixedRateSequence()
174 if (elapsedMillis <= cycles * delay) in testFixedRateSequence()
190 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) { in testFixedDelaySequence()
196 final int d = delay; in testFixedDelaySequence()
214 p.scheduleWithFixedDelay(task, 0, delay, MILLISECONDS); in testFixedDelaySequence()
215 final int totalDelayMillis = (cycles - 1) * delay; in testFixedDelaySequence()
DFutureTaskTest.java422 delay(LONG_DELAY_MS); in testCancelInterrupt()
496 delay(LONG_DELAY_MS); in testCancelInterrupt_taskFails()
639 delay(2*LONG_DELAY_MS); in testTimedGet_Cancellation()
/libcore/ojluni/src/test/java/util/concurrent/tck/
DScheduledExecutorTest.java218 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) { in testFixedRateSequence()
225 p.scheduleAtFixedRate(task, 0, delay, MILLISECONDS); in testFixedRateSequence()
226 final int totalDelayMillis = (cycles - 1) * delay; in testFixedRateSequence()
231 if (elapsedMillis <= cycles * delay) in testFixedRateSequence()
258 for (int delay = 1; delay <= 1_000; delay *= 3) { in testFixedRateSequenceSkipMultipleMissedFixedRateTasksEnabled()
265 final int thisDelay = delay; in testFixedRateSequenceSkipMultipleMissedFixedRateTasksEnabled()
278 p.scheduleAtFixedRate(task, 0, delay, MILLISECONDS); in testFixedRateSequenceSkipMultipleMissedFixedRateTasksEnabled()
279 final int totalDelayMillis = (cycles - 1) * delay; in testFixedRateSequenceSkipMultipleMissedFixedRateTasksEnabled()
284 if (elapsedMillis <= (cycles + slept - 1) * delay) { in testFixedRateSequenceSkipMultipleMissedFixedRateTasksEnabled()
311 for (int delay = 1; delay <= 1_000; delay *= 3) { in testFixedRateSequenceSkipMultipleMissedFixedRateTasksDisabled()
[all …]
DJSR166TestCase.java1117 static void delay(long millis) throws InterruptedException { in delay() method in JSR166TestCase
1292 delay(millis);
1313 delay(millis);
1617 delay(millis);
1976 delay(SHORT_DELAY_MS);
1982 delay(SHORT_DELAY_MS);
1988 delay(SMALL_DELAY_MS);
1995 delay(SMALL_DELAY_MS);
2002 delay(SMALL_DELAY_MS);
2009 delay(MEDIUM_DELAY_MS);
[all …]
DSubmissionPublisherTest.java939 long delay = timeoutMillis();
941 assertTrue(p.offer(i, delay, MILLISECONDS, null) >= 0);
943 assertTrue(p.offer(5, delay, MILLISECONDS, null) < 0);
945 assertTrue(p.offer(6, delay, MILLISECONDS, null) < 0);
947 assertTrue(millisElapsedSince(startTime) >= delay);
972 long delay = timeoutMillis(); in testHandledDroppedTimedOffer() local
974 assertTrue(p.offer(i, delay, MILLISECONDS, (s, x) -> noopHandle(calls)) >= 0); in testHandledDroppedTimedOffer()
976 assertTrue(p.offer(5, delay, MILLISECONDS, (s, x) -> noopHandle(calls)) < 0); in testHandledDroppedTimedOffer()
978 assertTrue(p.offer(6, delay, MILLISECONDS, (s, x) -> noopHandle(calls)) < 0); in testHandledDroppedTimedOffer()
979 assertTrue(millisElapsedSince(startTime) >= delay); in testHandledDroppedTimedOffer()
[all …]
DScheduledExecutorSubclassTest.java260 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) { in testFixedRateSequence()
267 p.scheduleAtFixedRate(task, 0, delay, MILLISECONDS); in testFixedRateSequence()
268 final int totalDelayMillis = (cycles - 1) * delay; in testFixedRateSequence()
273 if (elapsedMillis <= cycles * delay) in testFixedRateSequence()
290 for (int delay = 1; delay <= LONG_DELAY_MS; delay *= 3) { in testFixedDelaySequence()
296 final int d = delay; in testFixedDelaySequence()
314 p.scheduleWithFixedDelay(task, 0, delay, MILLISECONDS); in testFixedDelaySequence()
315 final int totalDelayMillis = (cycles - 1) * delay; in testFixedDelaySequence()
DFutureTaskTest.java469 delay(LONG_DELAY_MS); in testCancelInterrupt()
545 delay(LONG_DELAY_MS); in testCancelInterrupt_taskFails()
693 delay(2*LONG_DELAY_MS); in testTimedGet_Cancellation()
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/lang/
DObjectTest.java324 final int delay = 200; // milliseconds in test_waitJ() local
331 lock.wait(delay, 0); in test_waitJ()
333 long error = (after - before - delay); in test_waitJ()
344 if (error > (1000 + delay) || count == toLong.length) { in test_waitJ()
DThreadTest.java26 int delay; field in ThreadTest.SimpleThread
32 this.wait(delay); in run()
42 delay = d; in SimpleThread()
47 volatile int delay; field in ThreadTest.YieldThread
58 delay = d; in YieldThread()
/libcore/luni/src/test/java/libcore/java/nio/channels/
DFileIOInterruptTest.java481 delay(100); in waitForThreadToBlock()
485 delay(100); in waitForThreadToBlock()
520 delay(500); in waitForThreadToBlock()
569 delay(100); in waitForThreadToBlock()
573 delay(100); in waitForThreadToBlock()
621 delay(500); in waitForThreadToBlock()
708 private static void delay(int millis) { in delay() method in FileIOInterruptTest
/libcore/support/src/test/java/tests/support/
DSupport_TestWebServer.java184 public void setDelay(int delay) { in setDelay() argument
185 mDelay = delay; in setDelay()
319 private int delay = 0; field in Support_TestWebServer.Worker
330 Worker setDelay(int delay) { in setDelay() argument
331 this.delay = delay; in setDelay()
/libcore/ojluni/src/test/java/nio/channels/Selector/
DSelectWithConsumer.java728 void scheduleWakeup(Selector sel, long delay, TimeUnit unit) { in scheduleWakeup() argument
729 POOL.schedule(() -> sel.wakeup(), delay, unit); in scheduleWakeup() local
732 void scheduleInterrupt(Thread t, long delay, TimeUnit unit) { in scheduleInterrupt() argument
733 POOL.schedule(() -> t.interrupt(), delay, unit); in scheduleInterrupt() local
736 void scheduleClose(Closeable c, long delay, TimeUnit unit) { in scheduleClose() argument
743 }, delay, unit); in scheduleClose()
746 void scheduleWrite(WritableByteChannel sink, ByteBuffer buf, long delay, TimeUnit unit) { in scheduleWrite() argument
753 }, delay, unit); in scheduleWrite()
/libcore/luni/src/test/java/libcore/java/lang/
DOldThreadTest.java29 int delay; field in OldThreadTest.SimpleThread
35 this.wait(delay); in run()
45 delay = d; in SimpleThread()
/libcore/ojluni/annotations/hiddenapi/java/util/concurrent/
DExecutors.java277 java.lang.Runnable command, long delay, java.util.concurrent.TimeUnit unit) { in schedule() argument
283 long delay, in schedule() argument
299 long delay, in scheduleWithFixedDelay() argument
/libcore/ojluni/src/main/java/java/lang/
DThread.java1639 long delay = millis - now; in join() local
1640 if (delay <= 0) { in join()
1643 lock.wait(delay); in join()
/libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/net/
DServerSocketTest.java248 int delay = (int) (finish.getTime() - start.getTime()); in test_accept() local
249 assertTrue("timeout too soon: " + delay + " " + start.getTime() in test_accept()
250 + " " + finish.getTime(), delay >= 490); in test_accept()
/libcore/ojluni/annotations/mmodule/java/util/concurrent/
DCompletableFuture.annotated.java180 public static java.util.concurrent.Executor delayedExecutor(long delay, java.util.concurrent.TimeUn… in delayedExecutor() argument
182 public static java.util.concurrent.Executor delayedExecutor(long delay, java.util.concurrent.TimeUn… in delayedExecutor() argument

12