- Sort Score
- Num 10 results
- Language All
Results 1 - 8 of 8 for scheduleWithFixedDelay (0.1 seconds)
-
guava-tests/test/com/google/common/util/concurrent/ListeningScheduledExecutorServiceTest.java
Runnable command = () -> {}; ListenableScheduledFuture<?> future = executorService.scheduleWithFixedDelay(command, Duration.ofDays(8), Duration.ofHours(16)); assertThat(future.get()).isEqualTo("scheduleWithFixedDelay"); assertThat(recordedCommand).isSameInstanceAs(command); assertThat(recordedTimeUnit).isEqualTo(NANOSECONDS);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 6.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java
@SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored Future<?> possiblyIgnoredError = testExecutor.scheduleWithFixedDelay(() -> {}, 100, 10, MINUTES); mock.assertLastMethodCalled("scheduleWithFixedDelay", 100, 10, MINUTES); @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnoredCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java
@SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored Future<?> possiblyIgnoredError = testExecutor.scheduleWithFixedDelay(() -> {}, 100, 10, MINUTES); mock.assertLastMethodCalled("scheduleWithFixedDelay", 100, 10, MINUTES); @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnoredCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
final ScheduledExecutorService executor = new ScheduledThreadPoolExecutor(10) { @Override public ScheduledFuture<?> scheduleWithFixedDelay( Runnable command, long initialDelay, long delay, TimeUnit unit) { return future = super.scheduleWithFixedDelay(command, initialDelay, delay, unit); } }; public void testServiceStartStop() throws Exception {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 22.8K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
final ScheduledExecutorService executor = new ScheduledThreadPoolExecutor(10) { @Override public ScheduledFuture<?> scheduleWithFixedDelay( Runnable command, long initialDelay, long delay, TimeUnit unit) { return future = super.scheduleWithFixedDelay(command, initialDelay, delay, unit); } }; public void testServiceStartStop() throws Exception {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 22.8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
} @Override public ListenableScheduledFuture<?> scheduleWithFixedDelay( Runnable command, long initialDelay, long delay, TimeUnit unit) { NeverSuccessfulListenableFutureTask task = new NeverSuccessfulListenableFutureTask(command); ScheduledFuture<?> scheduled = delegate.scheduleWithFixedDelay(task, initialDelay, delay, unit);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 45.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
assertExecutionException(future, ex); assertEquals(5, runnable.count); assertEquals(0, delegate.getQueue().size()); runnable = new ThrowingRunnable(5, ex); future = service.scheduleWithFixedDelay(runnable, 1, 1, MILLISECONDS); assertExecutionException(future, ex); assertEquals(5, runnable.count); assertEquals(0, delegate.getQueue().size()); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 26.1K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
assertExecutionException(future, ex); assertEquals(5, runnable.count); assertEquals(0, delegate.getQueue().size()); runnable = new ThrowingRunnable(5, ex); future = service.scheduleWithFixedDelay(runnable, 1, 1, MILLISECONDS); assertExecutionException(future, ex); assertEquals(5, runnable.count); assertEquals(0, delegate.getQueue().size()); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 26.1K bytes - Click Count (0)