- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 47 for AbstractFuture (0.27 sec)
-
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
this.delegate = delegate; } @Override public void run() { if (isCancelled()) { return; } if (delegate instanceof AbstractFuture) { AbstractFuture<? extends V> other = (AbstractFuture<? extends V>) delegate; value = other.value; throwable = other.throwable; // don't copy the mayInterruptIfRunning bit, for consistency with the server, to ensure that
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jan 22 19:37:41 GMT 2024 - 12.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
} } try { Class<?> abstractFuture = AbstractFuture.class; WAITERS_OFFSET = unsafe.objectFieldOffset(abstractFuture.getDeclaredField("waiters")); LISTENERS_OFFSET = unsafe.objectFieldOffset(abstractFuture.getDeclaredField("listeners")); VALUE_OFFSET = unsafe.objectFieldOffset(abstractFuture.getDeclaredField("value"));
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java
import junit.framework.TestSuite; /** * Tests our AtomicHelper fallback strategies in AbstractFuture. * * <p>On different platforms AbstractFuture uses different strategies for its core synchronization * primitives. The strategies are all implemented as subtypes of AtomicHelper and the strategy is * selected in the static initializer of AbstractFuture. This is convenient and performant but
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 16 03:24:50 GMT 2021 - 6.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UntrustedInputFutureTest.java
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() { AbstractFuture<Integer> future = new AbstractFuture<Integer>() {};
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.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() { AbstractFuture<Integer> future = new TrustedFuture<Integer>() {};
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.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() { AbstractFuture<Integer> future = new TrustedFuture<Integer>() {};
Java - Registered: Fri Apr 26 12:43:10 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/AbstractAbstractFutureTest.java
/** * Base class for tests for emulated {@link AbstractFuture} that allow subclasses to swap in a * different "source Future" for {@link AbstractFuture#setFuture} calls. */ @GwtCompatible(emulated = true) abstract class AbstractAbstractFutureTest extends TestCase { private TestedFuture<Integer> future; private AbstractFuture<Integer> delegate; abstract AbstractFuture<Integer> newDelegate(); @Override
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 15.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
NonListenableSettableFuture<String> abstractFuture = NonListenableSettableFuture.create(); abstractFuture.set(DATA1); ExecutorSpy spy = new ExecutorSpy(directExecutor()); ListenableFuture<String> listenableFuture = listenInPoolThread(abstractFuture, spy); SingleCallListener singleCallListener = new SingleCallListener(); singleCallListener.expectCall();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 9.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 46.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java
import junit.framework.TestSuite; /** * Tests our AtomicHelper fallback strategies in AbstractFuture. * * <p>On different platforms AbstractFuture uses different strategies for its core synchronization * primitives. The strategies are all implemented as subtypes of AtomicHelper and the strategy is * selected in the static initializer of AbstractFuture. This is convenient and performant but
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 16 03:24:50 GMT 2021 - 6.2K bytes - Viewed (0)