- Sort Score
- Num 10 results
- Language All
Results 1 - 6 of 6 for AbstractFuture (0.1 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) -
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/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) -
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() {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 16.2K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/MoreExecutors.java
return scheduledDelegate.compareTo(other); } } @GwtIncompatible // TODO private static final class NeverSuccessfulListenableFutureTask extends AbstractFuture.TrustedFuture<@Nullable Void> implements Runnable { private final Runnable delegate; NeverSuccessfulListenableFutureTask(Runnable delegate) { this.delegate = checkNotNull(delegate); }
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Oct 08 18:55:33 GMT 2025 - 45.2K bytes - Click Count (0) -
guava/src/com/google/common/cache/LocalCache.java
} } } static class LoadingValueReference<K, V> implements ValueReference<K, V> { volatile ValueReference<K, V> oldValue; // TODO(fry): rename get, then extend AbstractFuture instead of containing SettableFuture final SettableFuture<V> futureValue = SettableFuture.create(); final Stopwatch stopwatch = Stopwatch.createUnstarted(); public LoadingValueReference() {Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Sep 11 19:35:11 GMT 2025 - 148.9K bytes - Click Count (0)