- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for getDelay (0.18 sec)
-
src/test/java/org/codelibs/fess/helper/IntervalControlHelperTest.java
intervalControlHelper.ruleList.clear(); intervalControlHelper.addIntervalRule("22:15", "2:45", "1", 3000); assertEquals(0, intervalControlHelper.getDelay()); intervalControlHelper.addIntervalRule("22:15", "2:45", "2", 4000); assertEquals(4000, intervalControlHelper.getDelay()); } public void test_1215() throws ParseException {
Java - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 4.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/IntervalControlHelper.java
ThreadUtil.sleepQuietly(crawlerWaitMillis); } } public void delayByRules() { final long delay = getDelay(); if (delay > 0) { ThreadUtil.sleep(delay); } } protected long getDelay() { if (ruleList.isEmpty()) { return 0; } final Calendar cal = getCurrentCal();
Java - Registered: Mon Apr 22 08:04:10 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 5.8K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
return new NeverScheduledFuture<>(); } @Override public long getDelay(TimeUnit unit) { return Long.MAX_VALUE; } @Override public int compareTo(Delayed other) { return Longs.compare(getDelay(NANOSECONDS), other.getDelay(NANOSECONDS)); } } }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Fri May 26 22:04:00 GMT 2023 - 6.7K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
return new NeverScheduledFuture<>(); } @Override public long getDelay(TimeUnit unit) { return Long.MAX_VALUE; } @Override public int compareTo(Delayed other) { return Longs.compare(getDelay(NANOSECONDS), other.getDelay(NANOSECONDS)); } } }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 26 22:04:00 GMT 2023 - 6.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
// to produce the message throws (probably StackOverflowError from delegate.toString()) try { if (timer != null) { long overDelayMs = Math.abs(timer.getDelay(TimeUnit.MILLISECONDS)); if (overDelayMs > 10) { // Not all timing drift is worth reporting message += " (timeout delayed by " + overDelayMs + " ms after scheduled time)"; }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 7.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListeningScheduledExecutorServiceTest.java
} ImmediateScheduledFuture(ListenableFuture<V> delegate) { super(delegate); } @Override public long getDelay(TimeUnit unit) { return 0; } @Override public int compareTo(Delayed other) { return 0; } }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Mar 17 20:45:59 GMT 2020 - 6.1K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
throws InterruptedException, ExecutionException, TimeoutException { Preconditions.checkNotNull(unit, "unit must not be null!"); return get(); } @Override public long getDelay(TimeUnit unit) { Preconditions.checkNotNull(unit, "unit must not be null!"); return 0; } @Override public int compareTo(Delayed other) {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Oct 06 00:47:57 GMT 2021 - 6.4K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
throws InterruptedException, ExecutionException, TimeoutException { Preconditions.checkNotNull(unit, "unit must not be null!"); return get(); } @Override public long getDelay(TimeUnit unit) { Preconditions.checkNotNull(unit, "unit must not be null!"); return 0; } @Override public int compareTo(Delayed other) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Oct 06 00:47:57 GMT 2021 - 6.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
implements ScheduledFuture<V> { @Override protected Future<V> delegate() { throw new UnsupportedOperationException("test should not care about this"); } @Override public long getDelay(TimeUnit unit) { throw new UnsupportedOperationException("test should not care about this"); } @Override public int compareTo(Delayed other) {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 22.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
implements ScheduledFuture<V> { @Override protected Future<V> delegate() { throw new UnsupportedOperationException("test should not care about this"); } @Override public long getDelay(TimeUnit unit) { throw new UnsupportedOperationException("test should not care about this"); } @Override public int compareTo(Delayed other) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 22.5K bytes - Viewed (0)