- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 4,110 for futures (0.12 sec)
-
android/guava/src/com/google/common/cache/CacheLoader.java
* the thread's interrupt status is set * @since 11.0 */ @GwtIncompatible // Futures public ListenableFuture<V> reload(K key, V oldValue) throws Exception { checkNotNull(key); checkNotNull(oldValue); return Futures.immediateFuture(load(key)); } /** * Computes or retrieves the values corresponding to {@code keys}. This method is called by {@link
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 19 20:20:14 UTC 2022 - 9.6K 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: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Nov 15 16:33:21 UTC 2022 - 6.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
import java.util.logging.Level; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /** * A helper which does some thread-safe operations for aggregate futures, which must be implemented * differently in GWT. Namely: * * <ul> * <li>Lazily initializes a set of seen exceptions * <li>Decrements a counter atomically * </ul> */ @GwtCompatible(emulated = true)
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 28 20:40:51 UTC 2024 - 8.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/tests/mlrt/tf_to_mlrt.mlir
// CHECK: [[promises:%.*]]:3, [[futures:%.*]]:3 = "tf_mlrt.allocate_futures" // CHECK-SAME: num_futures = 3 %promise_b, %promise_c, %promise_d, %future_b, %future_c, %future_d = "tf_mlrt.allocate_futures"() {num_futures = 3 : i32, resultSegmentSizes = array<i32: 3, 3>} : () -> (!mlrt.promise, !mlrt.promise, !mlrt.promise, !mlrt.future, !mlrt.future, !mlrt.future)
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri May 31 20:44:15 UTC 2024 - 24.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
try { sourceResult = getDone(localInputFuture); } catch (CancellationException e) { // TODO(user): verify future behavior - unify logic with getFutureValue in AbstractFuture. This // code should be unreachable with correctly implemented Futures. // Cancel this future and return. // At this point, inputFuture is cancelled and outputFuture doesn't exist, so the value of
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 10.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* Future} is "completed" even if it is cancelled while its underlying work continues on a * thread, an RPC, etc. The {@code Future} is also "completed" if it fails "early" -- for * example, if the deadline expires on a {@code Future} returned from {@link * Futures#withTimeout} while the {@code Future} it wraps continues its underlying work. So
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedInputs.java
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: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 13:46:56 UTC 2023 - 6.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/tests/mlrt/parallelization.mlir
// CHECK: return // CHECK-LABEL: func @main() // CHECK: [[PROMISES:%.*]]:3, [[FUTURES:%.*]]:3 = "mlrt.allocate_control_futures" // CHECK: mlrt.async([[PROMISES]]#2) {callee = @main_stream_4 // CHECK: mlrt.async([[FUTURES]]#2, [[PROMISES]]#1) {callee = @main_stream_3 // CHECK: mlrt.async([[FUTURES]]#1, [[PROMISES]]#0) {callee = @main_stream_2 // CHECK: mlrt.async([[FUTURES]]#0) {callee = @main_stream_1 // CHECK: mlrt.await_handle
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Jun 08 22:07:30 UTC 2023 - 15K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FutureCallback.java
@ElementTypesAreNonnullByDefault 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: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 05 22:27:35 UTC 2021 - 1.6K bytes - Viewed (0) -
android/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: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Apr 06 12:56:11 UTC 2023 - 6.3K bytes - Viewed (0)