- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for ListenableFuture (0.41 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
* #setFuture(ListenableFuture)}. */ private static final class AsyncTransformFuture< I extends @Nullable Object, O extends @Nullable Object> extends AbstractTransformFuture< I, O, AsyncFunction<? super I, ? extends O>, ListenableFuture<? extends O>> { AsyncTransformFuture(
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) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
private static final class TestCallable implements AsyncCallable<@Nullable Void> { private final ListenableFuture<@Nullable Void> future; private boolean called = false; private TestCallable(ListenableFuture<@Nullable Void> future) { this.future = future; } @Override public ListenableFuture<@Nullable Void> call() throws Exception { called = true; return future; } }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
private static final class TestCallable implements AsyncCallable<@Nullable Void> { private final ListenableFuture<@Nullable Void> future; private boolean called = false; private TestCallable(ListenableFuture<@Nullable Void> future) { this.future = future; } @Override public ListenableFuture<@Nullable Void> call() throws Exception { called = true; return future; } }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
} FluentFuture() {} /** * Converts the given {@code ListenableFuture} to an equivalent {@code FluentFuture}. * * <p>If the given {@code ListenableFuture} is already a {@code FluentFuture}, it is returned * directly. If not, it is wrapped in a {@code FluentFuture} that delegates all calls to the * original {@code ListenableFuture}. */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 11 19:08:44 GMT 2023 - 18.7K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
implements ListenableFuture<V> { static final boolean GENERATE_CANCELLATION_CAUSES = false; /** * Tag interface marking trusted subclasses. This enables some optimizations. The implementation * of this interface must also be an AbstractFuture and must not override or expose for overriding * any of the public methods of ListenableFuture. */
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/MoreExecutors.java
* incomplete and the {@code ListenableFuture} later completes normally, the * listener runs in the thread that completes the {@code ListenableFuture}. * <li>When a listener is attached to a {@code ListenableFuture} and the {@code * ListenableFuture} gets cancelled, the listener runs immediately in the thread that
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* {@link Callable#call()} will not be invoked. */ public <T extends @Nullable Object> ListenableFuture<T> submit( Callable<T> callable, Executor executor) { checkNotNull(callable); checkNotNull(executor); return submitAsync( new AsyncCallable<T>() { @Override public ListenableFuture<T> call() throws Exception { return immediateFuture(callable.call()); }
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) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
} catch (Throwable t) { throwableFromOtherThread.set(t); } } }); otherThread.start(); ListenableFuture<?> future = executor.submit(incrementTask); assertTrue(future.isDone()); assertListenerRunImmediately(future); assertEquals(1, threadLocalCount.get().intValue()); otherThread.join(1000);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (3) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
} public void testSetFuture_misbehavingFutureThrows() throws Exception { SettableFuture<String> future = SettableFuture.create(); ListenableFuture<String> badFuture = new ListenableFuture<String>() { @Override public boolean cancel(boolean interrupt) { return false; } @Override
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) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
} catch (Throwable t) { throwableFromOtherThread.set(t); } } }); otherThread.start(); ListenableFuture<?> future = executor.submit(incrementTask); assertTrue(future.isDone()); assertListenerRunImmediately(future); assertEquals(1, threadLocalCount.get().intValue()); otherThread.join(1000);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (0)