- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,401 for futuna (0.36 sec)
-
tensorflow/compiler/mlir/tfrt/tests/mlrt/fuse_mlrt_ops.mlir
// RUN: tf-tfrt-opt -split-input-file -tf-mlrt-fuse %s | FileCheck %s // CHECK-LABEL: @main // CHECK-SAME: ([[f0:%.*]]: !mlrt.future, [[f1:%.*]]: !mlrt.future, [[f2:%.*]]: !mlrt.future) func.func @main(%f0: !mlrt.future, %f1: !mlrt.future, %f2: !mlrt.future) -> (!tf_mlrt.tensor, !tf_mlrt.tensor, !tf_mlrt.tensor) { // CHECK-NEXT: [[t:%.*]]:3 = tf_mlrt.await_all [[f0]], [[f1]], [[f2]] // CHECK-NOT: tf_mlrt.await // CHECK-NEXT: return [[t]]#0, [[t]]#1, [[t]]#2
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jul 07 23:57:30 UTC 2023 - 3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Uninterruptibles.java
@ParametricNullness public static <V extends @Nullable Object> V getUninterruptibly( Future<V> future, Duration timeout) throws ExecutionException, TimeoutException { return getUninterruptibly(future, toNanosSaturated(timeout), TimeUnit.NANOSECONDS); } /** * Invokes {@code future.}{@link Future#get(long, TimeUnit) get(timeout, unit)} uninterruptibly. * * <p>Similar methods: * * <ul>
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 18.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
private final ListenableFuture<@Nullable Void> future; private boolean called = false; private TestCallable(ListenableFuture<@Nullable Void> future) { this.future = future; } @Override public ListenableFuture<@Nullable Void> call() throws Exception { called = true; return future; } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 16.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingFuture.java
import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import org.checkerframework.checker.nullness.qual.Nullable; /** * A {@link Future} which forwards all its method calls to another future. Subclasses should * override one or more methods to modify the behavior of the backing future as desired per the <a
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Mar 04 12:28:17 UTC 2022 - 3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ForwardingFuture.java
import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import org.checkerframework.checker.nullness.qual.Nullable; /** * A {@link Future} which forwards all its method calls to another future. Subclasses should * override one or more methods to modify the behavior of the backing future as desired per the <a
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Mar 04 12:28:17 UTC 2022 - 3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
} /** * Returns a new {@code Future} whose result is asynchronously derived from the result of this * {@code Future}. If the input {@code Future} fails, the returned {@code Future} fails with the * same exception (and the function is not invoked). * * <p>More precisely, the returned {@code Future} takes its result from a {@code Future} produced
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 11 19:08:44 UTC 2023 - 18.7K bytes - Viewed (0) -
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) -
guava/src/com/google/common/util/concurrent/FuturesGetChecked.java
@CanIgnoreReturnValue @ParametricNullness static <V extends @Nullable Object, X extends Exception> V getChecked( Future<V> future, Class<X> exceptionClass) throws X { return getChecked(bestGetCheckedTypeValidator(), future, exceptionClass); } /** Implementation of {@link Futures#getChecked(Future, Class)}. */ @CanIgnoreReturnValue @VisibleForTesting @ParametricNullness
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:40:56 UTC 2024 - 11.9K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
final SettableFuture<@Nullable Void> future = SettableFuture.create(); Object x = new Object() { @Override protected void finalize() { future.set(null); } }; x = null; // Hint to the JIT that x is unreachable GcFinalization.awaitDone(future); assertTrue(future.isDone()); assertFalse(future.isCancelled()); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 7.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/SimpleTimeLimiter.java
checkNotNull(timeoutUnit); checkPositiveTimeout(timeoutDuration); Future<T> future = executor.submit(callable); try { return amInterruptible ? future.get(timeoutDuration, timeoutUnit) : getUninterruptibly(future, timeoutDuration, timeoutUnit); } catch (InterruptedException e) { future.cancel(true); throw e; } catch (ExecutionException e) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 27 14:21:11 UTC 2023 - 9.7K bytes - Viewed (0)