- Sort Score
- Num 10 results
- Language All
Results 151 - 160 of 1,134 for futures (0.04 seconds)
-
guava-tests/test/com/google/common/util/concurrent/UntrustedInputFutureTest.java
@Override AbstractFuture<@Nullable Integer> newDelegate() { AbstractFuture<@Nullable Integer> future = new AbstractFuture<@Nullable Integer>() {}; assertFalse(future instanceof TrustedFuture); // sanity check return future; }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 15:59:55 GMT 2026 - 1.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java
SettableFuture<Integer> future = SettableFuture.create(); assertTrue(future.set(42)); // Later attempts to set the future should return false. assertFalse(future.set(23)); assertFalse(future.setException(new Exception("bar"))); assertFalse(future.setFuture(SettableFuture.create())); // Check that the future has been set properly. assertTrue(future.isDone()); assertFalse(future.isCancelled());
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.4K bytes - Click Count (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFutureState.java
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Feb 21 02:38:37 GMT 2025 - 1.9K bytes - Click Count (0) -
futures/failureaccess/src/com/google/common/util/concurrent/internal/InternalFutures.java
* return value of this method as its cause * </ul> */ public static Throwable tryInternalFastPathGetFailure(InternalFutureFailureAccess future) { return future.tryInternalFastPathGetFailure(); } private InternalFutures() {}Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Jan 18 02:54:30 GMT 2025 - 1.7K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
} public void testCancel_notDoneNoInterrupt() throws Exception { Future<?> future = newFutureInstance(); assertTrue(future.cancel(false)); assertTrue(future.isCancelled()); assertTrue(future.isDone()); assertThat(tryInternalFastPathGetFailure(future)).isNull(); CancellationException e = assertThrows(CancellationException.class, future::get); assertThat(e.getCause()).isNotNull(); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 6.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
} public void testCancel_notDoneNoInterrupt() throws Exception { Future<?> future = newFutureInstance(); assertTrue(future.cancel(false)); assertTrue(future.isCancelled()); assertTrue(future.isDone()); assertThat(tryInternalFastPathGetFailure(future)).isNull(); CancellationException e = assertThrows(CancellationException.class, future::get); assertThat(e.getCause()).isNotNull(); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 6.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestPlatform.java
/** * Retrieves the result of a {@code Future} known to be done but uses the {@code get(long, * TimeUnit)} overload in order to test that method. */ static <V extends @Nullable Object> V getDoneFromTimeoutOverload(Future<V> future) throws ExecutionException { checkState(future.isDone(), "Future was expected to be done: %s", future); try { return getUninterruptibly(future, 0, SECONDS); } catch (TimeoutException e) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 2.7K bytes - Click Count (0) -
android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
() -> { taskDone = true; return taskDone; }; List<Future<Boolean>> futureList = executor.invokeAll(ImmutableList.of(task), 10, MILLISECONDS); Future<Boolean> future = futureList.get(0); assertFalse(taskDone); assertTrue(future.isDone()); assertThrows(CancellationException.class, future::get); }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 3.3K bytes - Click Count (0) -
guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java
() -> { taskDone = true; return taskDone; }; List<Future<Boolean>> futureList = executor.invokeAll(ImmutableList.of(task), 10, MILLISECONDS); Future<Boolean> future = futureList.get(0); assertFalse(taskDone); assertTrue(future.isDone()); assertThrows(CancellationException.class, future::get); }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 3.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java
SettableFuture<Integer> future = SettableFuture.create(); assertTrue(future.set(42)); // Later attempts to set the future should return false. assertFalse(future.set(23)); assertFalse(future.setException(new Exception("bar"))); assertFalse(future.setFuture(SettableFuture.create())); // Check that the future has been set properly. assertTrue(future.isDone()); assertFalse(future.isCancelled());
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.4K bytes - Click Count (0)