- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 37 for SetFuture (2.57 sec)
-
android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java
} @Override public void run() { InterruptibleTask<?> localTask = task; if (localTask != null) { localTask.run(); } /* * In the Async case, we may have called setFuture(pendingFuture), in which case afterDone() * won't have been called yet. */ this.task = null; } @Override protected void afterDone() { super.afterDone();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Oct 01 17:18:04 UTC 2021 - 5.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
return; } inputFuture = null; if (localInputFuture.isCancelled()) { @SuppressWarnings("unchecked") boolean unused = setFuture((ListenableFuture<O>) localInputFuture); // Respects cancellation cause setting return; } /* * Any of the setException() calls below can fail if the output Future is cancelled between now
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 10.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractCatchingFuture.java
* succeeded. */ set(uncheckedCastNullableTToT(sourceResult)); return; } if (!isInstanceOfThrowableClass(throwable, localExceptionType)) { setFuture(localInputFuture); // TODO(cpovirk): Test that fallback is not run in this case. return; } @SuppressWarnings("unchecked") // verified safe by isInstanceOfThrowableClass
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 8.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedInputFutureTest.java
import com.google.common.annotations.GwtCompatible; import com.google.common.util.concurrent.AbstractFuture.TrustedFuture; /** * Tests for {@link AbstractFuture} that use a {@link TrustedFuture} for {@link * AbstractFuture#setFuture} calls. */ @GwtCompatible public class TrustedInputFutureTest extends AbstractAbstractFutureTest { @Override AbstractFuture<Integer> newDelegate() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 16 19:54:45 UTC 2020 - 1.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractCatchingFuture.java
* succeeded. */ set(uncheckedCastNullableTToT(sourceResult)); return; } if (!isInstanceOfThrowableClass(throwable, localExceptionType)) { setFuture(localInputFuture); // TODO(cpovirk): Test that fallback is not run in this case. return; } @SuppressWarnings("unchecked") // verified safe by isInstanceOfThrowableClass
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 8.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TrustedInputFutureTest.java
import com.google.common.annotations.GwtCompatible; import com.google.common.util.concurrent.AbstractFuture.TrustedFuture; /** * Tests for {@link AbstractFuture} that use a {@link TrustedFuture} for {@link * AbstractFuture#setFuture} calls. */ @GwtCompatible public class TrustedInputFutureTest extends AbstractAbstractFutureTest { @Override AbstractFuture<Integer> newDelegate() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 16 19:54:45 UTC 2020 - 1.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UntrustedInputFutureTest.java
import com.google.common.annotations.GwtCompatible; import com.google.common.util.concurrent.AbstractFuture.TrustedFuture; /** * Tests for {@link AbstractFuture} that use a non-{@link TrustedFuture} for {@link * AbstractFuture#setFuture} calls. */ @GwtCompatible public class UntrustedInputFutureTest extends AbstractAbstractFutureTest { @Override AbstractFuture<Integer> newDelegate() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 16 19:54:45 UTC 2020 - 1.2K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
"RuntimeException while executing runnable " + command + " with executor " + executor, e); } } } private final class SetFuture implements Runnable { final ListenableFuture<? extends V> delegate; SetFuture(ListenableFuture<? extends V> delegate) { this.delegate = delegate; } @Override public void run() { if (isCancelled()) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jan 22 19:37:41 UTC 2024 - 12.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/UntrustedInputFutureTest.java
import com.google.common.annotations.GwtCompatible; import com.google.common.util.concurrent.AbstractFuture.TrustedFuture; /** * Tests for {@link AbstractFuture} that use a non-{@link TrustedFuture} for {@link * AbstractFuture#setFuture} calls. */ @GwtCompatible public class UntrustedInputFutureTest extends AbstractAbstractFutureTest { @Override AbstractFuture<Integer> newDelegate() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Dec 16 19:54:45 UTC 2020 - 1.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
return; } inputFuture = null; if (localInputFuture.isCancelled()) { @SuppressWarnings("unchecked") boolean unused = setFuture((ListenableFuture<O>) localInputFuture); // Respects cancellation cause setting return; } /* * Any of the setException() calls below can fail if the output Future is cancelled between now
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 10.6K bytes - Viewed (0)