- Sort Score
- Result 10 results
- Languages All
Results 11 - 13 of 13 for TrustedListenableFutureTask (0.13 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
List<Future<String>> results; results = service.invokeAll(callables); assertThat(getOnlyElement(results)).isInstanceOf(TrustedListenableFutureTask.class); results = service.invokeAll(callables, 1, SECONDS); assertThat(getOnlyElement(results)).isInstanceOf(TrustedListenableFutureTask.class); /* * TODO(cpovirk): move ForwardingTestCase somewhere common, and use it to * test the forwarded methods
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 28.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
ListenableFuture<@Nullable Void> oldFuture = ref.getAndSet(newFuture); // Invoke our task once the previous future completes. TrustedListenableFutureTask<T> taskFuture = TrustedListenableFutureTask.create(task); oldFuture.addListener(taskFuture, taskExecutor); ListenableFuture<T> outputFuture = Futures.nonCancellationPropagating(taskFuture);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
ClosingCallable<V> callable, Executor executor) { checkNotNull(callable); CloseableList closeables = new CloseableList(); TrustedListenableFutureTask<V> task = TrustedListenableFutureTask.create( new Callable<V>() { @Override @ParametricNullness public V call() throws Exception {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Oct 08 19:36:35 UTC 2024 - 98.5K bytes - Viewed (0)