- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 388 for FUTURE (0.04 sec)
-
android/guava-tests/benchmark/com/google/common/util/concurrent/FuturesGetCheckedBenchmark.java
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 6.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java
} @Override public void onFailure(Throwable t) { failureCalls[0]++; } }; addCallback(future, callback, directExecutor()); future.set(result); assertEquals(result, future.get()); assertThat(successCalls[0]).isEqualTo(1); assertThat(failureCalls[0]).isEqualTo(0); } public void testOnSuccessThrowsError() throws Exception {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Jul 14 14:44:08 UTC 2025 - 6.7K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/Platform.java
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 { checkNotNull(unit); return future.getFromAlreadyDoneTrustedFuture(); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Feb 27 16:15:49 UTC 2025 - 2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SettableFuture.java
public boolean setException(Throwable throwable) { return super.setException(throwable); } @CanIgnoreReturnValue @Override public boolean setFuture(ListenableFuture<? extends V> future) { return super.setFuture(future); } private SettableFuture() {}
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 2.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedInputs.java
static final OtherThrowable OTHER_THROWABLE = new OtherThrowable(); static final Future<String> FAILED_FUTURE_OTHER_THROWABLE = immediateFailedFuture(OTHER_THROWABLE); static final Error ERROR = new Error("mymessage"); static final Future<String> FAILED_FUTURE_ERROR = immediateFailedFuture(ERROR); static final Future<String> RUNTIME_EXCEPTION_FUTURE = UncheckedThrowingFuture.throwingRuntimeException(RUNTIME_EXCEPTION);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 6.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FutureCallback.java
@GwtCompatible public interface FutureCallback<V extends @Nullable Object> { /** Invoked with the result of the {@code Future} computation when it is successful. */ void onSuccess(@ParametricNullness V result); /** * Invoked when a {@code Future} computation fails or is canceled. * * <p>If the future's {@link Future#get() get} method throws an {@link ExecutionException}, then
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 1.5K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/http/HcHttpClientTest.java
// return responseData; // } // } // return null; // } // }); // } // List<Future<ResponseData>> futureList = executorService.invokeAll(list); // for (Future<ResponseData> future : futureList) { // ResponseData responseData = future.get(); // if (responseData != null) { // System.out.println("status: " // + responseData.getHttpStatusCode()
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 11.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
* Future, then a call setException() would likely also overflow. * * - If the stack overflowed after set()/setValue() stored its result, then a call to * setException() will be a no-op because the Future is already done. * * Both scenarios are bad: The output Future might never complete, or, if it does complete, it
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Feb 20 18:03:37 UTC 2025 - 10.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
((finalState & (CANCELLED | INTERRUPTED)) != 0) ? new CancellationException("Future.cancel() was called.") : t; releaseShared(finalState); } else if (getState() == COMPLETING) { // If some other thread is currently completing the future, block until // they are done so we can guarantee completion. acquireShared(-1); }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Jan 30 16:59:10 UTC 2025 - 13.7K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java
// Callableタスク(複数)を実行する final ExecutorService executor = Executors.newFixedThreadPool(numTasks); try { final List<Future<Integer>> futures = executor.invokeAll(tasks); for (final Future<Integer> future : futures) { future.get(); } } catch (final InterruptedException e) { // no thing to do } catch (final ExecutionException e) {
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Mar 15 06:52:00 UTC 2025 - 3.2K bytes - Viewed (0)