Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for AggregateFutureState (0.06 sec)

  1. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

        /** Performs an atomic compare-and-set of {@link AggregateFutureState#seenExceptionsField}. */
        abstract void compareAndSetSeenExceptions(
            AggregateFutureState<?> state, @Nullable Set<Throwable> expect, Set<Throwable> update);
    
        /** Performs an atomic decrement-and-get of {@link AggregateFutureState#remainingField}. */
        abstract int decrementAndGetRemainingCount(AggregateFutureState<?> state);
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  2. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AggregateFutureState.java

    package com.google.common.util.concurrent;
    
    import static com.google.common.collect.Sets.newHashSet;
    
    import java.util.Set;
    import org.jspecify.annotations.Nullable;
    
    /** Emulation of AggregateFutureState. */
    abstract class AggregateFutureState<OutputT extends @Nullable Object>
        extends AbstractFuture.TrustedFuture<OutputT> {
      // Lazily initialized the first time we see an exception; not released until all the input futures
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateDefaultAtomicHelperTest.java

    package com.google.common.util.concurrent;
    
    import static com.google.common.truth.Truth.assertThat;
    
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Tests that {@link AggregateFutureState} uses the expected {@code AtomicHelper} implementation.
     *
     * <p>We have more thorough testing of {@code AtomicHelper} implementations in {@link
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Apr 05 15:44:19 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java

    /**
     * Tests our AtomicHelper fallback strategy in AggregateFutureState.
     *
     * <p>On different platforms AggregateFutureState uses different strategies for its core
     * synchronization primitives. The strategies are all implemented as subtypes of AtomicHelper and
     * the strategy is selected in the static initializer of AggregateFutureState. This is convenient
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

             * the case of the Samsung bug, and we do that by breaking AtomicReferenceFieldUpdater.
             * Breaking AtomicReferenceFieldUpdater not only forces AggregateFutureState to fall back to
             * another implementation but also forces AbstractFutureState to be able to do the
             * same—hence the try-catch here.
             *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java

         *
         * SynchronizedHelper also ends up getting used under the JVM during
         * AggregateFutureStateFallbackAtomicHelperTest, as discussed in a comment in
         * AggregateFutureState.
         *
         * Here, we check that we're able to force AbstractFutureState to select SynchronizedHelper, and
         * below, we actually run the AbstractFutureTest methods under that scenario.
         */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 8.1K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

        "ShortCircuitBoolean")
    abstract class AggregateFuture<InputT extends @Nullable Object, OutputT extends @Nullable Object>
        extends AggregateFutureState<OutputT> {
      private static final LazyLogger logger = new LazyLogger(AggregateFuture.class);
    
      /**
       * The input futures. After {@link #init}, this field is read only by {@link #afterDone()} (to
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 16K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

       * since Android should normally succed in using UnsafeAtomicHelper and thus never even try the
       * problematic AtomicReferenceFieldUpdaterAtomicHelper code path. However, the same problem *does*
       * matter with AggregateFutureState, which does not have an Unsafe-based helper.
       *
       * This same problem is one of the reasons for us to likewise use package-private for the fields
       * in Waiter.
       */
    
      /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
Back to top