- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for AggregateFutureState (0.12 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)