Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 72 for cancelled (0.08 sec)

  1. guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

            return (getState() & (COMPLETED | CANCELLED | INTERRUPTED)) != 0;
          }
    
          /** Checks if the state is {@link #CANCELLED} or {@link #INTERRUPTED}. */
          boolean isCancelled() {
            return (getState() & (CANCELLED | INTERRUPTED)) != 0;
          }
    
          /** Checks if the state is {@link #INTERRUPTED}. */
          boolean wasInterrupted() {
            return getState() == INTERRUPTED;
          }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  2. android/guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java

    import java.util.concurrent.Executor;
    
    /** Measures the size of AbstractFuture implementations. */
    public class AbstractFutureFootprintBenchmark {
    
      enum State {
        NOT_DONE,
        FINISHED,
        CANCELLED,
        FAILED
      }
    
      @Param State state;
      @Param Impl impl;
    
      @Param({"0", "1", "5", "10"})
      int numListeners;
    
      @Param({"0", "1", "5", "10"})
      int numThreads;
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 16 17:21:56 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

      public boolean cancel(boolean mayInterruptIfRunning) {
        logger.get().log(FINER, "cancelling {0}", this);
        boolean cancelled = future.cancel(mayInterruptIfRunning);
        if (cancelled) {
          close();
        }
        return cancelled;
      }
    
      private void close() {
        logger.get().log(FINER, "closing {0}", this);
        closeables.close();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Oct 08 19:36:35 UTC 2024
    - 98.5K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/Futures.java

       * either from cancellation or because an input future has completed. If N futures are passed in,
       * and M delegates are cancelled, the remaining M input futures will be cancelled once N - M of
       * the input futures complete. If all the delegates are cancelled, all the input futures will be
       * too.
       *
       * @since 17.0
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

          return;
        }
    
        /*
         * Any of the setException() calls below can fail if the output Future is cancelled between now
         * and then. This means that we're silently swallowing an exception -- maybe even an Error. But
         * this is no worse than what FutureTask does in that situation. Additionally, because the
         * Future was cancelled, its listeners have been run, so its consumers will not hang.
         *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 11K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/Futures.java

       * either from cancellation or because an input future has completed. If N futures are passed in,
       * and M delegates are cancelled, the remaining M input futures will be cancelled once N - M of
       * the input futures complete. If all the delegates are cancelled, all the input futures will be
       * too.
       *
       * @since 17.0
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.4K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/MoreExecutors.java

            boolean cancelled = super.cancel(mayInterruptIfRunning);
            if (cancelled) {
              // Unless it is cancelled, the delegate may continue being scheduled
              scheduledDelegate.cancel(mayInterruptIfRunning);
    
              // TODO(user): Cancel "this" if "scheduledDelegate" is cancelled.
            }
            return cancelled;
          }
    
          @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/FluentFuture.java

       * input future and that of the future returned by the chain function. That is, if the returned
       * {@code Future} is cancelled, it will attempt to cancel the other two, and if either of the
       * other two is cancelled, the returned {@code Future} will receive a callback in which it will
       * attempt to cancel itself.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/Uninterruptibles.java

       *       Futures#getUnchecked}.
       * </ul>
       *
       * @throws ExecutionException if the computation threw an exception
       * @throws CancellationException if the computation was cancelled
       */
      @CanIgnoreReturnValue
      @ParametricNullness
      public static <V extends @Nullable Object> V getUninterruptibly(Future<V> future)
          throws ExecutionException {
        boolean interrupted = false;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        }
    
        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 Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.7K bytes
    - Viewed (0)
Back to top