Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 79 for isCancelled (0.2 sec)

  1. android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

                future.set(null);
              }
            };
        x = null; // Hint to the JIT that x is unreachable
        GcFinalization.awaitDone(future);
        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
      }
    
      public void testAwaitDone_Future_Cancel() {
        final SettableFuture<@Nullable Void> future = SettableFuture.create();
        Object x =
            new Object() {
              @Override
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 7.4K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

          return super.get(timeout, unit);
        }
    
        @Override
        public final boolean isDone() {
          return super.isDone();
        }
    
        @Override
        public final boolean isCancelled() {
          return super.isCancelled();
        }
    
        @Override
        public final void addListener(Runnable listener, Executor executor) {
          super.addListener(listener, executor);
        }
    
        @CanIgnoreReturnValue
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 22 21:17:24 GMT 2024
    - 63K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

          return sync.get();
        }
    
        @Override
        public boolean isDone() {
          return sync.isDone();
        }
    
        @Override
        public boolean isCancelled() {
          return sync.isCancelled();
        }
    
        @CanIgnoreReturnValue
        @Override
        public boolean cancel(boolean mayInterruptIfRunning) {
          if (!sync.cancel(mayInterruptIfRunning)) {
            return false;
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed May 09 15:17:25 GMT 2018
    - 13.6K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

          return sync.get();
        }
    
        @Override
        public boolean isDone() {
          return sync.isDone();
        }
    
        @Override
        public boolean isCancelled() {
          return sync.isCancelled();
        }
    
        @CanIgnoreReturnValue
        @Override
        public boolean cancel(boolean mayInterruptIfRunning) {
          if (!sync.cancel(mayInterruptIfRunning)) {
            return false;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Apr 06 12:56:11 GMT 2023
    - 13.6K bytes
    - Viewed (0)
  5. futures/failureaccess/src/com/google/common/util/concurrent/internal/InternalFutureFailureAccess.java

       * does not include "was cancelled." To be explicit: If this method returns a non-null value,
       * then:
       *
       * <ul>
       *   <li>{@code isDone()} must return {@code true}
       *   <li>{@code isCancelled()} must return {@code false}
       *   <li>{@code get()} must not block, and it must throw an {@code ExecutionException} with the
       *       return value of this method as its cause
       * </ul>
       *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 2.3K bytes
    - Viewed (0)
  6. futures/failureaccess/src/com/google/common/util/concurrent/internal/InternalFutures.java

       * does not include "was cancelled." To be explicit: If this method returns a non-null value,
       * then:
       *
       * <ul>
       *   <li>{@code isDone()} must return {@code true}
       *   <li>{@code isCancelled()} must return {@code false}
       *   <li>{@code get()} must not block, and it must throw an {@code ExecutionException} with the
       *       return value of this method as its cause
       * </ul>
       */
      public static
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 1.7K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

      public final void run() {
        ListenableFuture<? extends I> localInputFuture = inputFuture;
        F localFunction = function;
        if (isCancelled() | localInputFuture == null | localFunction == null) {
          return;
        }
        inputFuture = null;
    
        if (localInputFuture.isCancelled()) {
          @SuppressWarnings("unchecked")
          boolean unused =
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/ImmediateFuture.java

      }
    
      @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() {
        return true;
      }
    
      @Override
      public String toString() {
        // Behaviour analogous to AbstractFuture#toString().
    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)
  9. android/guava/src/com/google/common/util/concurrent/AbstractCatchingFuture.java

        F localFallback = fallback;
        if (localInputFuture == null | localExceptionType == null | localFallback == null
            // This check, unlike all the others, is a volatile read
            || isCancelled()) {
          return;
        }
        inputFuture = null;
    
        // For an explanation of the cases here, see the comments on AbstractTransformFuture.run.
        V sourceResult = null;
        Throwable throwable = null;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 8.7K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java

        }
    
        @Override
        public V get(long timeout, TimeUnit unit) {
          throw new AssertionFailedError();
        }
    
        @Override
        public boolean isCancelled() {
          throw new AssertionFailedError();
        }
    
        @Override
        public boolean isDone() {
          /*
           * If isDone is true during the call to listenInPoolThread,
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 9.7K bytes
    - Viewed (0)
Back to top