- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 27 for AbstractFuture (0.09 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
RuntimeException exception = new RuntimeException("you didn't say the magic word!"); AbstractFuture<String> evilFuture = new AbstractFuture<String>() { @Override public void addListener(Runnable r, Executor e) { throw exception; } }; AbstractFuture<String> normalFuture = new AbstractFuture<String>() {}; normalFuture.setFuture(evilFuture);
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:45:32 GMT 2025 - 46.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java
/** * Base class for tests for emulated {@link AbstractFuture} that allow subclasses to swap in a * different "source Future" for {@link AbstractFuture#setFuture} calls. */ @GwtCompatible @NullUnmarked abstract class AbstractAbstractFutureTest extends TestCase { private TestedFuture<Integer> future; private AbstractFuture<Integer> delegate; abstract AbstractFuture<Integer> newDelegate(); @OverrideCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 15.4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
RuntimeException exception = new RuntimeException("you didn't say the magic word!"); AbstractFuture<String> evilFuture = new AbstractFuture<String>() { @Override public void addListener(Runnable r, Executor e) { throw exception; } }; AbstractFuture<String> normalFuture = new AbstractFuture<String>() {}; normalFuture.setFuture(evilFuture);
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:45:32 GMT 2025 - 46.8K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java
import java.util.HashSet; import java.util.Set; import java.util.concurrent.Executor; import org.jspecify.annotations.NullUnmarked; /** Measures the size of AbstractFuture implementations. */ @NullUnmarked public class AbstractFutureFootprintBenchmark { enum State { NOT_DONE, FINISHED, CANCELLED, FAILED } @Param State state;Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
import java.util.concurrent.Executor; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /** Tests for {@link AbstractFuture} with the cancellation cause system property set */ @AndroidIncompatible // custom classloading @NullUnmarked public class AbstractFutureCancellationCauseTest extends TestCase { private ClassLoader oldClassLoader;Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 16:03:47 GMT 2025 - 6.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java
import org.jspecify.annotations.NullUnmarked; /** * Tests our AtomicHelper fallback strategies in AbstractFuture. * * <p>On different platforms AbstractFuture 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 AbstractFuture. This is convenient and performant but
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 7.3K bytes - Click Count (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/Platform.java
throw (Error) t; } } static <V extends @Nullable Object> V get(AbstractFuture<V> future) throws InterruptedException, ExecutionException { return future.getFromAlreadyDoneTrustedFuture(); } static <V extends @Nullable Object> V get(AbstractFuture<V> future, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Feb 27 16:15:49 GMT 2025 - 2K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Platform.java
throw (Error) t; } } static <V extends @Nullable Object> V get(AbstractFuture<V> future) throws InterruptedException, ExecutionException { return future.blockingGet(); } static <V extends @Nullable Object> V get(AbstractFuture<V> future, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 2.1K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/Platform.java
throw (Error) t; } } static <V extends @Nullable Object> V get(AbstractFuture<V> future) throws InterruptedException, ExecutionException { return future.blockingGet(); } static <V extends @Nullable Object> V get(AbstractFuture<V> future, long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 2.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java
} /** Constructor for use by {@link AbstractFuture}. */ AbstractFutureState() {} /* * We put various static objects here rather than in AbstractFuture so that they're initialized in * time for AbstractFutureState to potentially use them during class initialization. * (AbstractFutureState class initialization can log, and that logging could in theory call intoCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 33.2K bytes - Click Count (0)