- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 564 for futuna (0.14 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/UncheckedThrowingFuture.java
UncheckedThrowingFuture<V> future = new UncheckedThrowingFuture<V>(); future.complete(checkNotNull(error)); return future; } public static <V> ListenableFuture<V> throwingRuntimeException(RuntimeException e) { UncheckedThrowingFuture<V> future = new UncheckedThrowingFuture<V>(); future.complete(checkNotNull(e)); return future; }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 12 20:02:10 UTC 2018 - 3.2K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java
@GwtIncompatible public class MockFutureListener implements Runnable { private final CountDownLatch countDownLatch; private final ListenableFuture<?> future; public MockFutureListener(ListenableFuture<?> future) { this.countDownLatch = new CountDownLatch(1); this.future = future; future.addListener(this, directExecutor()); } @Override public void run() { countDownLatch.countDown(); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:12:42 UTC 2023 - 3K bytes - Viewed (0) -
platforms/software/publish/src/main/java/org/gradle/api/tasks/Upload.java
* This task is <strong>no longer supported</strong> and will <strong>throw an exception</strong> if you try to use it. * It is preserved solely for backwards compatibility and may be removed in a future version. * * @deprecated This class is scheduled for removal in a future version. To upload artifacts, use the `maven-publish` or `ivy-publish` plugins instead. */ @Deprecated // TODO:Finalize Upload Removal - Issue #21439
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 22:15:44 UTC 2024 - 6.1K bytes - Viewed (0) -
android/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) -
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) -
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-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) -
src/cmd/vendor/golang.org/x/tools/internal/versions/features.go
Go1_21 = "go1.21" Go1_22 = "go1.22" ) // Future is an invalid unknown Go version sometime in the future. // Do not use directly with Compare. const Future = "" // AtLeast reports whether the file version v comes after a Go release. // // Use this predicate to enable a behavior once a certain Go release // has happened (and stays enabled in the future). func AtLeast(v, release string) bool { if v == Future {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 02:20:05 UTC 2024 - 1.3K 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)