Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 8 of 8 for scheduleWithFixedDelay (0.11 seconds)

  1. 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)
  2. 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/FutureReturnValueIgnored
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.5K bytes
    - Click Count (0)
  3. 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/FutureReturnValueIgnored
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.5K bytes
    - Click Count (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
Back to Top