- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 13 for SettableFuture (0.08 seconds)
-
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
} settableFuture.set(null); getDone(allAsList(results)); } public void testAvoidsStackOverflow_manyCancelled() throws Exception { SettableFuture<@Nullable Void> settableFuture = SettableFuture.create(); ListenableFuture<@Nullable Void> unused = serializer.submitAsync(() -> settableFuture, directExecutor()); for (int i = 0; i < 50_000; i++) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 13.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
} settableFuture.set(null); getDone(allAsList(results)); } public void testAvoidsStackOverflow_manyCancelled() throws Exception { SettableFuture<@Nullable Void> settableFuture = SettableFuture.create(); ListenableFuture<@Nullable Void> unused = serializer.submitAsync(() -> settableFuture, directExecutor()); for (int i = 0; i < 50_000; i++) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 13.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
// together. Now it should only be limited by available memory (and time) public void testSetFuture_stackOverflow() { SettableFuture<String> orig = SettableFuture.create(); SettableFuture<String> prev = orig; for (int i = 0; i < 100000; i++) { SettableFuture<String> curr = SettableFuture.create(); prev.setFuture(curr); prev = curr; } // prev represents the 'innermost' future
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 45.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
// together. Now it should only be limited by available memory (and time) public void testSetFuture_stackOverflow() { SettableFuture<String> orig = SettableFuture.create(); SettableFuture<String> prev = orig; for (int i = 0; i < 100000; i++) { SettableFuture<String> curr = SettableFuture.create(); prev.setFuture(curr); prev = curr; } // prev represents the 'innermost' future
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 45.2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java
assertThat(getChecked(immediateFuture("foo"), TwoArgConstructorException.class)) .isEqualTo("foo"); } public void testGetCheckedUntimed_interrupted() { SettableFuture<String> future = SettableFuture.create(); Thread.currentThread().interrupt(); try { getChecked(future, TwoArgConstructorException.class); fail(); } catch (TwoArgConstructorException expected) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 16.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java
assertThat(getChecked(immediateFuture("foo"), TwoArgConstructorException.class)) .isEqualTo("foo"); } public void testGetCheckedUntimed_interrupted() { SettableFuture<String> future = SettableFuture.create(); Thread.currentThread().interrupt(); try { getChecked(future, TwoArgConstructorException.class); fail(); } catch (TwoArgConstructorException expected) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 16.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
static <V> NonListenableSettableFuture<V> create() { return new NonListenableSettableFuture<V>(); } final SettableFuture<V> delegate = SettableFuture.create(); @Override protected Future<V> delegate() { return delegate; } void set(V value) { delegate.set(value); } }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 10K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
static <V> NonListenableSettableFuture<V> create() { return new NonListenableSettableFuture<V>(); } final SettableFuture<V> delegate = SettableFuture.create(); @Override protected Future<V> delegate() { return delegate; } void set(V value) { delegate.set(value); } }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Mar 13 13:01:07 GMT 2026 - 10K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
} finally { service.shutdown(); } } public void testRejectedExecutionThrownWithMultipleCalls() throws Exception { CountDownLatch latch = new CountDownLatch(1); SettableFuture<?> future = SettableFuture.create(); Executor delegate = new Executor() { @Override public void execute(Runnable task) { if (future.set(null)) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 10.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
} finally { service.shutdown(); } } public void testRejectedExecutionThrownWithMultipleCalls() throws Exception { CountDownLatch latch = new CountDownLatch(1); SettableFuture<?> future = SettableFuture.create(); Executor delegate = new Executor() { @Override public void execute(Runnable task) { if (future.set(null)) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 10.5K bytes - Click Count (0)