Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for ListenableScheduledFuture (0.35 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>
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Dec 14 15:53:12 GMT 2021
    - 1.1K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/ListeningScheduledExecutorServiceTest.java

      private static class ImmediateScheduledFuture<V> extends SimpleForwardingListenableFuture<V>
          implements ListenableScheduledFuture<V> {
        static <V> ListenableScheduledFuture<V> of(V value) {
          return new ImmediateScheduledFuture<>(Futures.immediateFuture(value));
        }
    
        static <V> ListenableScheduledFuture<V> failed(Throwable t) {
          return new ImmediateScheduledFuture<>(Futures.immediateFailedFuture(t));
        }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Mar 17 20:45:59 GMT 2020
    - 6.1K bytes
    - Viewed (0)
  3. 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);
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 2.2K bytes
    - Viewed (0)
  4. 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(java.util.concurrent.Executors.callable(command), delay, unit);
      }
    
      @Override
      public <V> ListenableScheduledFuture<V> schedule(
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Oct 06 00:47:57 GMT 2021
    - 6.4K bytes
    - Viewed (0)
  5. 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(java.util.concurrent.Executors.callable(command), delay, unit);
      }
    
      @Override
      public <V> ListenableScheduledFuture<V> schedule(
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Oct 06 00:47:57 GMT 2021
    - 6.4K bytes
    - Viewed (0)
  6. 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();
        }
    
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri May 26 22:04:00 GMT 2023
    - 6.7K bytes
    - Viewed (0)
  7. 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();
        }
    
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Fri May 26 22:04:00 GMT 2023
    - 6.7K bytes
    - Viewed (0)
  8. android/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);
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 41.8K bytes
    - Viewed (0)
  9. android/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;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 25.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/Futures.java

       * @since 23.0
       */
      @J2ktIncompatible
      @GwtIncompatible // java.util.concurrent.ScheduledExecutorService
      @SuppressWarnings("GoodTime") // should accept a java.time.Duration
      // TODO(cpovirk): Return ListenableScheduledFuture?
      public static <O extends @Nullable Object> ListenableFuture<O> scheduleAsync(
          AsyncCallable<O> callable,
          long delay,
          TimeUnit timeUnit,
          ScheduledExecutorService executorService) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 59.6K bytes
    - Viewed (0)
Back to top