Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 39 for timed_out (0.15 sec)

  1. android/guava/src/com/google/common/collect/ForwardingBlockingDeque.java

        delegate().putLast(e);
      }
    
      @Override
      public boolean offerFirst(E e, long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().offerFirst(e, timeout, unit);
      }
    
      @Override
      public boolean offerLast(E e, long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().offerLast(e, timeout, unit);
      }
    
      @Override
      public E takeFirst() throws InterruptedException {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Mar 13 14:30:51 GMT 2023
    - 4.4K bytes
    - Viewed (0)
  2. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

      @Override
      public boolean isTerminated() {
        return delegate.isTerminated();
      }
    
      @Override
      public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
        Preconditions.checkNotNull(unit, "unit must not be null!");
        return delegate.awaitTermination(timeout, unit);
      }
    
      @Override
      public <T> ListenableFuture<T> submit(Callable<T> task) {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Oct 06 00:47:57 GMT 2021
    - 6.4K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ForwardingFluentFuture.java

      public V get() throws InterruptedException, ExecutionException {
        return delegate.get();
      }
    
      @Override
      @ParametricNullness
      public V get(long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException {
        return delegate.get(timeout, unit);
      }
    
      @Override
      public String toString() {
        return delegate.toString();
      }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed May 05 22:27:35 GMT 2021
    - 2.5K bytes
    - Viewed (0)
  4. guava/src/com/google/common/cache/Cache.java

       * value. Otherwise, a call that passes one {@code loader} may return the result of another call
       * with a differently behaving {@code loader}. For example, a call that requests a short timeout
       * for an RPC may wait for a similar call that requests a long timeout, or a call by an
       * unprivileged user may return a resource accessible only to a privileged user making a similar
    Java
    - Registered: Fri Apr 05 12:43:09 GMT 2024
    - Last Modified: Sun Aug 07 02:38:22 GMT 2022
    - 7.9K bytes
    - Viewed (1)
  5. android/guava/src/com/google/common/util/concurrent/ImmediateFuture.java

      // TODO(lukes): Consider throwing InterruptedException when appropriate.
      @Override
      @ParametricNullness
      public V get() {
        return value;
      }
    
      @Override
      @ParametricNullness
      public V get(long timeout, TimeUnit unit) throws ExecutionException {
        checkNotNull(unit);
        return get();
      }
    
      @Override
      public boolean isCancelled() {
        return false;
      }
    
      @Override
      public boolean isDone() {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 3.5K bytes
    - Viewed (0)
  6. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

          return shutdown;
        }
    
        @Override
        public boolean isTerminated() {
          return shutdown;
        }
    
        @Override
        public boolean awaitTermination(long timeout, TimeUnit unit) {
          return true;
        }
    
        @Override
        public void execute(Runnable runnable) {}
    
        @Override
        public <V> ListenableScheduledFuture<V> schedule(
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Fri May 26 22:04:00 GMT 2023
    - 6.7K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java

           */
          allowGetToComplete.await(1, SECONDS);
          throw new RuntimeException("expected, should be caught");
        }
    
        @Override
        public V get(long timeout, TimeUnit unit) {
          throw new AssertionFailedError();
        }
    
        @Override
        public boolean isCancelled() {
          throw new AssertionFailedError();
        }
    
        @Override
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 9.7K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/SimpleTimeLimiter.java

        } else {
          throw new UncheckedExecutionException(cause);
        }
      }
    
      private static void checkPositiveTimeout(long timeoutDuration) {
        checkArgument(timeoutDuration > 0, "timeout must be positive: %s", timeoutDuration);
      }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Jun 27 14:21:11 GMT 2023
    - 9.7K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/TimeLimiter.java

       * UncheckedTimeoutException} to the caller.
       *
       * <p>It is important to note that the primary purpose of the proxy object is to return control to
       * the caller when the timeout elapses; aborting the target method call is of secondary concern.
       * The particular nature and strength of the guarantees made by the proxy is
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri May 12 18:32:03 GMT 2023
    - 8.3K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/WrappingExecutorService.java

      }
    
      @Override
      public final <T extends @Nullable Object> List<Future<T>> invokeAll(
          Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
          throws InterruptedException {
        return delegate.invokeAll(wrapTasks(tasks), timeout, unit);
      }
    
      @Override
      public final <T extends @Nullable Object> T invokeAny(Collection<? extends Callable<T>> tasks)
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 5.5K bytes
    - Viewed (0)
Back to top