Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for ListenableScheduledFuture (0.12 sec)

  1. android/guava/src/com/google/common/util/concurrent/ListenableScheduledFuture.java

    /**
     * Helper interface to implement both {@link ListenableFuture} and {@link ScheduledFuture}.
     *
     * @author Anthony Zana
     * @since 15.0
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    public interface ListenableScheduledFuture<V extends @Nullable Object>
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Dec 14 15:53:12 UTC 2021
    - 1.1K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

      }
    
      @Override
      public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
        Preconditions.checkNotNull(command, "command must not be null");
        Preconditions.checkNotNull(unit, "unit must not be null!");
        return schedule(Executors.callable(command), delay, unit);
      }
    
      @Override
      public <V> ListenableScheduledFuture<V> schedule(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 02 18:21:29 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  3. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

      }
    
      @Override
      public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
        Preconditions.checkNotNull(command, "command must not be null");
        Preconditions.checkNotNull(unit, "unit must not be null!");
        return schedule(Executors.callable(command), delay, unit);
      }
    
      @Override
      public <V> ListenableScheduledFuture<V> schedule(
    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/src/com/google/common/util/concurrent/ListeningScheduledExecutorService.java

      /** @since 15.0 (previously returned ScheduledFuture) */
      @Override
      ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit);
    
      /** @since 15.0 (previously returned ScheduledFuture) */
      @Override
      <V extends @Nullable Object> ListenableScheduledFuture<V> schedule(
          Callable<V> callable, long delay, TimeUnit unit);
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  5. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

        }
    
        @Override
        public void execute(Runnable runnable) {}
    
        @Override
        public <V> ListenableScheduledFuture<V> schedule(
            Callable<V> callable, long delay, TimeUnit unit) {
          return NeverScheduledFuture.create();
        }
    
        @Override
        public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
          return NeverScheduledFuture.create();
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 23 14:18:12 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/MoreExecutors.java

        ScheduledListeningDecorator(ScheduledExecutorService delegate) {
          super(delegate);
          this.delegate = checkNotNull(delegate);
        }
    
        @Override
        public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
          TrustedListenableFutureTask<@Nullable Void> task =
              TrustedListenableFutureTask.create(command, null);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/Futures.java

      @GwtIncompatible // java.util.concurrent.ScheduledExecutorService
      @SuppressWarnings("Java7ApiChecker")
      @IgnoreJRERequirement // Users will use this only if they're already using Duration.
      // TODO(cpovirk): Return ListenableScheduledFuture?
      public static <O extends @Nullable Object> ListenableFuture<O> scheduleAsync(
          AsyncCallable<O> callable, Duration delay, ScheduledExecutorService executorService) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

              // caught and forwarded to the service the task would stop executing but the service would
              // have no idea.
              // TODO(lukes): consider building everything in terms of ListenableScheduledFuture then
              // the AbstractService could monitor the future directly. Rescheduling is still hard...
              // but it would help with some of these lock ordering issues.
              scheduleFailure = e;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/Futures.java

       * @since 28.0 (but only since 33.4.0 in the Android flavor)
       */
      @J2ktIncompatible
      @GwtIncompatible // java.util.concurrent.ScheduledExecutorService
      // TODO(cpovirk): Return ListenableScheduledFuture?
      public static <O extends @Nullable Object> ListenableFuture<O> scheduleAsync(
          AsyncCallable<O> callable, Duration delay, ScheduledExecutorService executorService) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
Back to top