Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 74 for TimeoutException (0.05 sec)

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

        delegate.awaitRunning(timeout, unit);
      }
    
      /**
       * @since 15.0
       */
      @Override
      public final void awaitTerminated() {
        delegate.awaitTerminated();
      }
    
      /**
       * @since 15.0
       */
      @Override
      public final void awaitTerminated(long timeout, TimeUnit unit) throws TimeoutException {
        delegate.awaitTerminated(timeout, unit);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.Semaphore;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.Lock;
    import org.jspecify.annotations.Nullable;
    
    /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.8K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

    import java.util.concurrent.ScheduledFuture;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Implementation of {@code Futures#withTimeout}.
     *
     * <p>Future that delegates to another but will finish early (via a {@link TimeoutException} wrapped
     * in an {@link ExecutionException}) if the specified duration expires. The delegate future is
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Test for {@link WrappingExecutorService}
     *
     * @author Chris Nokleberg
     */
    @NullUnmarked
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java

    import com.google.common.util.concurrent.AbstractFutureTest.TimedWaiterThread;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.TimeoutException;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    import org.jspecify.annotations.Nullable;
    
    /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 15.4K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java

    import com.google.common.util.concurrent.ForwardingListenableFuture.SimpleForwardingListenableFuture;
    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ScheduledExecutorService;
    import java.util.concurrent.TimeoutException;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullMarked;
    
    /**
     * Tests for {@link FluentFuture}. The tests cover only the basics for the API. The actual logic is
     * tested in {@link FuturesTest}.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java

    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import org.jspecify.annotations.Nullable;
    
    /**
     * An executor service which forwards all its method calls to another executor service. Subclasses
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Executor;
    import java.util.concurrent.FutureTask;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link FutureTask} that also implements the {@link ListenableFuture} interface. Unlike {@code
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/ListenableFutureTask.java

    import java.util.concurrent.ExecutionException;
    import java.util.concurrent.Executor;
    import java.util.concurrent.FutureTask;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A {@link FutureTask} that also implements the {@link ListenableFuture} interface. Unlike {@code
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/AbstractService.java

    import com.google.errorprone.annotations.concurrent.GuardedBy;
    import com.google.j2objc.annotations.WeakOuter;
    import java.util.concurrent.Executor;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import org.jspecify.annotations.Nullable;
    
    /**
     * Base class for implementing services that can handle {@link #doStart} and {@link #doStop}
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 20.3K bytes
    - Viewed (0)
Back to top