Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for scheduleWithFixedDelay (0.17 sec)

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

        @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored
        Future<?> possiblyIgnoredError =
            testExecutor.scheduleWithFixedDelay(DO_NOTHING, 100, 10, MINUTES);
        mock.assertLastMethodCalled("scheduleWithFixedDelay", 100, 10, MINUTES);
    
        @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored
    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

       * 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
       * calling thread. Tasks are run to completion before a {@code Future} is returned to the caller
    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

        throw new UnsupportedOperationException("scheduleAtFixedRate is not supported.");
      }
    
      @Override
      public ListenableScheduledFuture<?> scheduleWithFixedDelay(
          Runnable command, long initialDelay, long delay, TimeUnit unit) {
        throw new UnsupportedOperationException("scheduleWithFixedDelay is not supported.");
      }
    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

        throw new UnsupportedOperationException("scheduleAtFixedRate is not supported.");
      }
    
      @Override
      public ListenableScheduledFuture<?> scheduleWithFixedDelay(
          Runnable command, long initialDelay, long delay, TimeUnit unit) {
        throw new UnsupportedOperationException("scheduleWithFixedDelay is not supported.");
      }
    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

        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());
      }
    
    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

       * @author Luke Sandberg
       * @since 11.0
       */
      public abstract static class Scheduler {
        /**
         * Returns a {@link Scheduler} that schedules the task using the {@link
         * ScheduledExecutorService#scheduleWithFixedDelay} method.
         *
         * @param initialDelay the time to delay first execution
         * @param delay the delay between the termination of one execution and the commencement of the
         *     next
    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

        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());
      }
    
    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<?> scheduleWithFixedDelay(
            Runnable command, long initialDelay, long delay, TimeUnit unit) {
          NeverSuccessfulListenableFutureTask task = new NeverSuccessfulListenableFutureTask(command);
          ScheduledFuture<?> scheduled =
              delegate.scheduleWithFixedDelay(task, initialDelay, delay, 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