- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 26 for SetFuture (0.32 sec)
-
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() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Dec 16 19:54:45 GMT 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
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 10.6K bytes - Viewed (0) -
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();
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Oct 01 17:18:04 GMT 2021 - 5.6K 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() {
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Wed Dec 16 19:54:45 GMT 2020 - 1.2K bytes - Viewed (1) -
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() {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Dec 16 19:54:45 GMT 2020 - 1.2K 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() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Dec 16 19:54:45 GMT 2020 - 1.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
executor.execute(runnable); } }; Future<?> future = newFutureInstance(); future .getClass() .getMethod( "setFuture", future.getClass().getClassLoader().loadClass(ListenableFuture.class.getName())) .invoke(future, badFuture); CancellationException expected = assertThrows(CancellationException.class, () -> future.get());
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 6.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CombinedFuture.java
+ "Did you mean to return immediateFuture(null)? %s", callable); } @Override void setValue(ListenableFuture<V> value) { CombinedFuture.this.setFuture(value); } @Override String toPendingString() { return callable.toString(); } } @WeakOuter
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 6.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
* even with the above null checks.) */ timeoutFutureRef = null; if (delegate.isDone()) { timeoutFuture.setFuture(delegate); } else { try { ScheduledFuture<?> timer = timeoutFuture.timer; timeoutFuture.timer = null; // Don't include already elapsed delay in delegate.toString()
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 7.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
() -> { if (taskFuture.isDone()) { // Since the value of oldFuture can only ever be immediateFuture(null) or setFuture of // a future that eventually came from immediateFuture(null), this doesn't leak // throwables or completion values. newFuture.setFuture(oldFuture); } else if (outputFuture.isCancelled() && taskExecutor.trySetCancelled()) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 22.1K bytes - Viewed (0)