Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 69 of 69 for isCanceled (0.19 sec)

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

                future.set(null);
              }
            };
        unused = null; // Hint to the JIT that unused is unreachable
        GcFinalization.awaitDone(future);
        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
      }
    
      public void testAwaitDone_future_cancel() {
        SettableFuture<@Nullable Void> future = SettableFuture.create();
        Object unused =
            new Object() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 17:02:07 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  2. android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

                future.set(null);
              }
            };
        unused = null; // Hint to the JIT that unused is unreachable
        GcFinalization.awaitDone(future);
        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
      }
    
      public void testAwaitDone_future_cancel() {
        SettableFuture<@Nullable Void> future = SettableFuture.create();
        Object unused =
            new Object() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 17:02:07 UTC 2025
    - 7.9K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

        @RetainedLocalRef ListenableFuture<? extends I> localInputFuture = inputFuture;
        @RetainedLocalRef F localFunction = function;
        if (isCancelled() | localInputFuture == null | localFunction == null) {
          return;
        }
        inputFuture = null;
    
        if (localInputFuture.isCancelled()) {
          @SuppressWarnings("unchecked")
          boolean unused =
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Feb 20 18:03:37 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

        @RetainedLocalRef ListenableFuture<? extends I> localInputFuture = inputFuture;
        @RetainedLocalRef F localFunction = function;
        if (isCancelled() | localInputFuture == null | localFunction == null) {
          return;
        }
        inputFuture = null;
    
        if (localInputFuture.isCancelled()) {
          @SuppressWarnings("unchecked")
          boolean unused =
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Feb 20 18:03:37 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

          results.add(serializer.submit(Callables.returning(null), directExecutor()));
        }
    
        manualExecutorTask[0].run();
    
        for (Future<?> result : results) {
          if (!result.isCancelled()) {
            result.get(10, SECONDS);
          }
          // TODO(cpovirk): Verify that the cancelled futures are exactly ones that we expect.
        }
    
        assertThat(logHandler.getStoredLogRecords()).isEmpty();
      }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/FluentFuture.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
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/Futures.java

          @Override
          public boolean cancel(boolean mayInterruptIfRunning) {
            return input.cancel(mayInterruptIfRunning);
          }
    
          @Override
          public boolean isCancelled() {
            return input.isCancelled();
          }
    
          @Override
          public boolean isDone() {
            return input.isDone();
          }
    
          @Override
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

                // future that eventually came from immediateVoidFuture(), this doesn't leak throwables
                // or completion values.
                newFuture.setFuture(oldFuture);
              } else if (outputFuture.isCancelled() && taskExecutor.trySetCancelled()) {
                // If this CAS succeeds, we know that the provided callable will never be invoked,
                // so when oldFuture completes it is safe to allow the next submitted task to
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

                // future that eventually came from immediateVoidFuture(), this doesn't leak throwables
                // or completion values.
                newFuture.setFuture(oldFuture);
              } else if (outputFuture.isCancelled() && taskExecutor.trySetCancelled()) {
                // If this CAS succeeds, we know that the provided callable will never be invoked,
                // so when oldFuture completes it is safe to allow the next submitted task to
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 22.1K bytes
    - Viewed (0)
Back to top