Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 39 of 39 for AbstractFuture (0.07 sec)

  1. guava/src/com/google/common/hash/LittleEndianByteArray.java

        }
    
        return JavaLittleEndianBytes.INSTANCE;
      }
    
      // Compare AbstractFuture.VarHandleAtomicHelperMaker.
      private enum VarHandleLittleEndianBytesMaker {
        INSTANCE {
          /**
           * Implementation used by non-J2ObjC environments (aside, of course, from those that have
           * supersource for the entirety of {@link AbstractFuture}).
           */
          @Override
          @J2ObjCIncompatible
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Feb 12 03:49:18 UTC 2025
    - 12.3K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/UncheckedThrowingFuture.java

     * SettableFuture}).
     *
     * <p>Useful for testing the behavior of Future utilities against odd futures.
     *
     * @author Anthony Zana
     */
    @GwtCompatible
    @NullUnmarked
    final class UncheckedThrowingFuture<V> extends AbstractFuture<V> {
    
      public static <V> ListenableFuture<V> throwingError(Error error) {
        UncheckedThrowingFuture<V> future = new UncheckedThrowingFuture<V>();
        future.complete(checkNotNull(error));
        return future;
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  3. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

              }
            };
          }
        },
        ABSTRACT_FUTURE {
          @Override
          ExecutionListWrapper newExecutionList() {
            return new ExecutionListWrapper() {
              final AbstractFuture<?> future = new AbstractFuture<Object>() {};
    
              @Override
              public void add(Runnable runnable, Executor executor) {
                future.addListener(runnable, executor);
              }
    
              @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  4. android/guava-testlib/src/com/google/common/testing/NullPointerTester.java

         * versions of Java, and apparently Unsafe can cause SIGSEGV instead of NPE—almost as if it's
         * not safe.
         */
        concat(
                stream(AbstractFuture.class.getDeclaredMethods()),
                stream(requireNonNull(AbstractFuture.class.getSuperclass()).getDeclaredMethods()))
            .filter(
                m ->
                    m.getName().equals("getDoneValue")
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 24.9K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

      /**
       * A less abstract subclass of AbstractFuture. This can be used to optimize setFuture by ensuring
       * that {@link #get} calls exactly the implementation of {@link AbstractFuture#get}.
       */
      abstract static class TrustedFuture<V extends @Nullable Object> extends FluentFuture<V>
          implements AbstractFuture.Trusted<V> {
        @CanIgnoreReturnValue
        @Override
        @ParametricNullness
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/Futures.java

        InCompletionOrderState<T> state = new InCompletionOrderState<>(copy);
        ImmutableList.Builder<AbstractFuture<T>> delegatesBuilder =
            ImmutableList.builderWithExpectedSize(copy.length);
        for (int i = 0; i < copy.length; i++) {
          delegatesBuilder.add(new InCompletionOrderFuture<T>(state));
        }
    
        ImmutableList<AbstractFuture<T>> delegates = delegatesBuilder.build();
        for (int i = 0; i < copy.length; i++) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

     *   <li>Decrements a counter atomically
     * </ul>
     */
    @GwtCompatible
    @ReflectionSupport(value = ReflectionSupport.Level.FULL)
    abstract class AggregateFutureState<OutputT extends @Nullable Object>
        extends AbstractFuture.TrustedFuture<OutputT> {
      /*
       * The following fields are package-private, even though we intend never to use them outside this
       * file. For discussion, see AbstractFutureState.
       */
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java

          if (Modifier.isPublic(method.getModifiers())
              && method.getName().startsWith("test")
              /*
               * When we block access to AtomicReferenceFieldUpdater, we can't even reflect on
               * AbstractFuture, since it declares methods that use that type in their signatures.
               */
              && !method.getName().equals("testFutures_nullChecks")) {
            suite.addTest(
                TestSuite.createTest(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

            return object.toString();
          }
        };
      }
    
      public void testCancellationDuringReentrancy() throws Exception {
        TestLogHandler logHandler = new TestLogHandler();
        Logger.getLogger(AbstractFuture.class.getName()).addHandler(logHandler);
    
        List<Future<?>> results = new ArrayList<>();
        Runnable[] manualExecutorTask = new Runnable[1];
        Executor manualExecutor =
            new Executor() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 20:58:01 UTC 2025
    - 16.1K bytes
    - Viewed (0)
Back to top