Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for ScheduledFuture (0.1 sec)

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

        super(delegate);
        this.delegate = delegate;
      }
    
      @Override
      public final ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
        return delegate.schedule(wrapTask(command), delay, unit);
      }
    
      @Override
      public final <V extends @Nullable Object> ScheduledFuture<V> schedule(
          Callable<V> task, long delay, TimeUnit unit) {
        return delegate.schedule(wrapTask(task), delay, unit);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/WrappingScheduledExecutorService.java

        super(delegate);
        this.delegate = delegate;
      }
    
      @Override
      public final ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
        return delegate.schedule(wrapTask(command), delay, unit);
      }
    
      @Override
      public final <V extends @Nullable Object> ScheduledFuture<V> schedule(
          Callable<V> task, long delay, TimeUnit unit) {
        return delegate.schedule(wrapTask(task), delay, unit);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ListeningScheduledExecutorService.java

        extends ScheduledExecutorService, ListeningExecutorService {
    
      /** @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)
  4. android/guava/src/com/google/common/util/concurrent/ListenableScheduledFuture.java

     */
    
    package com.google.common.util.concurrent;
    
    import com.google.common.annotations.GwtCompatible;
    import java.util.concurrent.ScheduledFuture;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
     * Helper interface to implement both {@link ListenableFuture} and {@link ScheduledFuture}.
     *
     * @author Anthony Zana
     * @since 15.0
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Dec 14 15:53:12 UTC 2021
    - 1.1K bytes
    - Viewed (0)
  5. android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

    import java.util.List;
    import java.util.concurrent.Callable;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Future;
    import java.util.concurrent.ScheduledFuture;
    import junit.framework.TestCase;
    
    /**
     * Tests for TestingExecutors.
     *
     * @author Eric Chang
     */
    public class TestingExecutorsTest extends TestCase {
      private volatile boolean taskDone;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

        }
    
        @Override
        public ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
          assertThat(command).isInstanceOf(WrappedRunnable.class);
          lastMethodCalled = "scheduleRunnable";
          lastDelay = delay;
          lastUnit = unit;
          return null;
        }
    
        @Override
        public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

    import com.google.j2objc.annotations.RetainedLocalRef;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Future;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.ScheduledFuture;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import javax.annotation.CheckForNull;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        ListenableFuture<?> future;
        ScheduledFuture<?> delegateFuture;
    
        Runnable runnable =
            new Runnable() {
              @Override
              public void run() {}
            };
    
        future = service.schedule(runnable, 5, MINUTES);
        future.cancel(true);
        assertTrue(future.isCancelled());
        delegateFuture = (ScheduledFuture<?>) delegateQueue.element();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        ListenableFuture<?> future;
        ScheduledFuture<?> delegateFuture;
    
        Runnable runnable =
            new Runnable() {
              @Override
              public void run() {}
            };
    
        future = service.schedule(runnable, 5, MINUTES);
        future.cancel(true);
        assertTrue(future.isCancelled());
        delegateFuture = (ScheduledFuture<?>) delegateQueue.element();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/MoreExecutors.java

          public ListenableScheduledTask(
              ListenableFuture<V> listenableDelegate, ScheduledFuture<?> scheduledDelegate) {
            super(listenableDelegate);
            this.scheduledDelegate = scheduledDelegate;
          }
    
          @Override
          public boolean cancel(boolean mayInterruptIfRunning) {
            boolean cancelled = super.cancel(mayInterruptIfRunning);
            if (cancelled) {
    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