Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for scheduleAtFixedRate (0.14 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

        @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored
        Future<?> possiblyIgnoredError1 = testExecutor.scheduleAtFixedRate(DO_NOTHING, 3, 7, SECONDS);
        mock.assertLastMethodCalled("scheduleAtFixedRate", 3, 7, SECONDS);
      }
    
      private static final class WrappedCallable<T> implements Callable<T> {
        private final Callable<T> delegate;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  2. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

       * execute/submit/schedule}, as in {@link CallerRunsPolicy}. This applies both to individually
       * submitted tasks and to collections of tasks submitted via {@code invokeAll}, {@code invokeAny},
       * {@code schedule}, {@code scheduleAtFixedRate}, and {@code scheduleWithFixedDelay}. In the case
       * of tasks submitted by {@code invokeAll} or {@code invokeAny}, tasks will run serially on the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:18:12 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  3. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

          return 0;
        }
      }
    
      @Override
      public ListenableScheduledFuture<?> scheduleAtFixedRate(
          Runnable command, long initialDelay, long period, TimeUnit unit) {
        throw new UnsupportedOperationException("scheduleAtFixedRate is not supported.");
      }
    
      @Override
      public ListenableScheduledFuture<?> scheduleWithFixedDelay(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 02 18:21:29 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  4. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

          return 0;
        }
      }
    
      @Override
      public ListenableScheduledFuture<?> scheduleAtFixedRate(
          Runnable command, long initialDelay, long period, TimeUnit unit) {
        throw new UnsupportedOperationException("scheduleAtFixedRate is not supported.");
      }
    
      @Override
      public ListenableScheduledFuture<?> scheduleWithFixedDelay(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 02 18:21:29 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        RuntimeException ex = new RuntimeException();
    
        ListenableFuture<?> future;
    
        ThrowingRunnable runnable = new ThrowingRunnable(5, ex);
        future = service.scheduleAtFixedRate(runnable, 1, 1, MILLISECONDS);
        assertExecutionException(future, ex);
        assertEquals(5, runnable.count);
        assertEquals(0, delegate.getQueue().size());
    
        runnable = new ThrowingRunnable(5, ex);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

            }
          };
        }
    
        /**
         * Returns a {@link Scheduler} that schedules the task using the {@link
         * ScheduledExecutorService#scheduleAtFixedRate} method.
         *
         * @param initialDelay the time to delay first execution
         * @param period the period between successive executions of the task
         * @since 28.0 (but only since 33.4.0 in the Android flavor)
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        RuntimeException ex = new RuntimeException();
    
        ListenableFuture<?> future;
    
        ThrowingRunnable runnable = new ThrowingRunnable(5, ex);
        future = service.scheduleAtFixedRate(runnable, 1, 1, MILLISECONDS);
        assertExecutionException(future, ex);
        assertEquals(5, runnable.count);
        assertEquals(0, delegate.getQueue().size());
    
        runnable = new ThrowingRunnable(5, ex);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/MoreExecutors.java

        }
    
        @Override
        public ListenableScheduledFuture<?> scheduleAtFixedRate(
            Runnable command, long initialDelay, long period, TimeUnit unit) {
          NeverSuccessfulListenableFutureTask task = new NeverSuccessfulListenableFutureTask(command);
          ScheduledFuture<?> scheduled = delegate.scheduleAtFixedRate(task, initialDelay, period, unit);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
Back to top