- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,291 for futuna (0.12 sec)
-
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/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) -
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) -
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/WrappingExecutorServiceTest.java
MockExecutor mock = new MockExecutor(); TestExecutor testExecutor = new TestExecutor(mock); Future<?> f = testExecutor.submit(doNothing()); mock.assertLastMethodCalled("submit"); f.get(); } { MockExecutor mock = new MockExecutor(); TestExecutor testExecutor = new TestExecutor(mock); Future<String> f = testExecutor.submit(doNothing(), RESULT_VALUE); mock.assertLastMethodCalled("submit");
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Jan 05 19:41:03 UTC 2023 - 9.8K bytes - Viewed (0) -
test/typeparam/issue50561.dir/diameter.go
OnComplete(cb func(try Try[T]), ctx ...Executor) IsCompleted() bool // Value() Option[Try[T]] Failed() Future[error] Recover(f func(err error) T, ctx ...Executor) Future[T] RecoverWith(f func(err error) Future[T], ctx ...Executor) Future[T] } type Try[T any] struct { v *T err error } func (r Try[T]) IsSuccess() bool { return r.v != nil } type ByteBuffer struct { pos int buf []byte
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jan 13 22:58:24 UTC 2022 - 1.8K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
import java.util.concurrent.Executor; import java.util.concurrent.Future; import java.util.concurrent.RejectedExecutionException; import org.checkerframework.checker.nullness.qual.Nullable; /** * A {@link Future} that accepts completion listeners. Each listener has an associated executor, and * it is invoked using this executor once the future's computation is {@linkplain Future#isDone()
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 26 21:13:41 UTC 2023 - 8K bytes - Viewed (0)