HomeSort by relevance Sort by last modified time
    Searched refs:futures (Results 1 - 25 of 63) sorted by null

1 2 3

  /libcore/luni/src/main/java/java/util/concurrent/
AbstractExecutorService.java 126 ArrayList<Future<T>> futures = new ArrayList<>(ntasks); local
144 futures.add(ecs.submit(it.next()));
153 futures.add(ecs.submit(it.next()));
184 cancelAll(futures);
208 ArrayList<Future<T>> futures = new ArrayList<>(tasks.size()); local
212 futures.add(f);
215 for (int i = 0, size = futures.size(); i < size; i++) {
216 Future<T> f = futures.get(i);
223 return futures;
225 cancelAll(futures);
237 ArrayList<Future<T>> futures = new ArrayList<>(tasks.size()); local
    [all...]
  /external/guava/guava-bootstrap/src/java/util/concurrent/
AbstractExecutorService.java 46 List<Future<T>> futures= new ArrayList<Future<T>>(ntasks); local
55 futures.add(ecs.submit(it.next()));
64 futures.add(ecs.submit(it.next()));
99 for (Future<T> f : futures)
124 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); local
129 futures.add(f);
132 for (Future<T> f : futures) {
142 return futures;
145 for (Future<T> f : futures)
156 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()) local
    [all...]
  /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/
FuturesCombineBenchmark.java 32 * A benchmark for {@link Futures#combine}
40 Iterable<? extends ListenableFuture<?>> futures) {
41 ListenableFuture<?> trigger = Futures.successfulAsList(futures);
44 return Futures.transform(trigger, new AsyncFunction<Object, V>() {
47 return Futures.immediateFuture(combiner.call());
49 return Futures.immediateCancelledFuture();
51 return Futures.immediateFailedFuture(e.getCause()); // OK to rethrow on Error
60 Iterable<? extends ListenableFuture<?>> futures) {
61 return Futures.combine(combiner, executor, futures)
    [all...]
  /external/chromium-trace/catapult/dashboard/dashboard/
migrate_test_names.py 290 futures = []
299 futures += migrate_rows_result['put_future']
300 futures += migrate_rows_result['delete_future']
301 ndb.Future.wait_all(futures)
304 futures += _MigrateAnomalies(old_test_key, new_test_key)
305 futures += _MigrateStoppageAlerts(old_test_key, new_test_key)
307 if not futures:
311 ndb.Future.wait_all(futures)
419 futures = []
426 futures.append(entity.key.delete_async()
    [all...]
auto_triage.py 88 futures = []
98 futures.append(query.fetch_async(limit=_MAX_UNTRIAGED_ANOMALIES))
99 ndb.Future.wait_all(futures)
100 for future in futures:
dump_graph_json.py 141 futures = []
146 futures.append(q.fetch_async(limit=num_points))
147 ndb.Future.wait_all(futures)
148 for future in futures:
  /packages/apps/Camera2/src/com/android/camera/async/
Futures2.java 21 import com.google.common.util.concurrent.Futures;
29 * TODO Replace with Guava's com.google.common.util.concurrent.Futures once we
81 * Create a new joined future from two existing futures and a joining function
83 * result. The resulting future will fail if any of the dependent futures also
90 ListenableFuture<?>[] futures = new ListenableFuture<?>[2];
92 futures[0] = f1;
93 futures[1] = f2;
95 // Futures.allAsList is used instead of Futures.successfulAsList because
98 ListenableFuture<List<Object>> result = Futures.allAsList(futures)
    [all...]
  /external/guava/guava/src/com/google/common/util/concurrent/
Futures.java 75 public final class Futures {
76 private Futures() {}
321 * ListenableFuture<Integer> faultTolerantFuture = Futures.withFallback(
338 * ListenableFuture<Integer> faultTolerantFuture = Futures.withFallback(
399 * ListenableFuture<Integer> faultTolerantFuture = Futures.withFallback(
416 * ListenableFuture<Integer> faultTolerantFuture = Futures.withFallback(
842 * exception types. The reason for this is that {@code Futures.transform} used
844 * throw checked exceptions. Nowadays, {@code Futures.transform} has an
    [all...]
MoreExecutors.java 678 List<Future<T>> futures = Lists.newArrayListWithCapacity(ntasks); local
694 futures.add(submitAndAddQueueListener(executorService, it.next(), futureQueue));
703 futures.add(submitAndAddQueueListener(executorService, it.next(), futureQueue));
736 for (Future<T> f : futures) {
    [all...]
  /libcore/jsr166-tests/src/test/java/jsr166/
AbstractExecutorServiceTest.java 365 List<Future<String>> futures = e.invokeAll(l); local
366 assertEquals(1, futures.size());
368 futures.get(0).get();
385 List<Future<String>> futures = e.invokeAll(l); local
386 assertEquals(2, futures.size());
387 for (Future<String> future : futures)
549 List<Future<String>> futures =
551 assertEquals(1, futures.size());
553 futures.get(0).get();
570 List<Future<String>> futures
    [all...]
ScheduledExecutorSubclassTest.java 1039 List<Future<String>> futures = e.invokeAll(l); local
1059 List<Future<String>> futures = e.invokeAll(l); local
    [all...]
ScheduledExecutorTest.java 988 List<Future<String>> futures = e.invokeAll(l); local
1008 List<Future<String>> futures = e.invokeAll(l); local
    [all...]
ThreadPoolExecutorSubclassTest.java 1622 List<Future<String>> futures = e.invokeAll(l); local
1645 List<Future<String>> futures = e.invokeAll(l); local
    [all...]
ThreadPoolExecutorTest.java 1629 List<Future<String>> futures = e.invokeAll(l); local
1652 List<Future<String>> futures = e.invokeAll(l); local
    [all...]
ForkJoinPoolTest.java 752 List<Future<String>> futures = e.invokeAll(l); local
753 assertEquals(1, futures.size());
755 futures.get(0).get();
772 List<Future<String>> futures = e.invokeAll(l); local
773 assertEquals(2, futures.size());
774 for (Future<String> future : futures)
    [all...]
  /external/guava/guava-tests/test/com/google/common/util/concurrent/
WrappingExecutorServiceTest.java 100 List<Future<String>> futures = testExecutor.invokeAll(tasks); local
102 checkResults(futures);
109 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); local
111 checkResults(futures);
135 private static void checkResults(List<Future<String>> futures)
137 for (int i = 0; i < futures.size(); i++) {
138 assertEquals(RESULT_VALUE + i, futures.get(i).get());
  /cts/tests/tests/hardware/src/android/hardware/cts/helpers/sensoroperations/
ParallelSensorOperation.java 96 ArrayList<Future<SensorOperation>> futures = new ArrayList<>(); local
105 futures.add(future);
118 Future<SensorOperation> future = futures.get(i);
  /external/guava/guava-tests/test/com/google/common/collect/
ConcurrentHashMultisetBasherTest.java 72 List<Future<int[]>> futures = Lists.newArrayListWithExpectedSize(nTasks); local
74 futures.add(pool.submit(new MutateTask(multiset, keys)));
78 for (Future<int[]> future : futures) {
  /external/dagger2/core/src/test/java/dagger/internal/
DoubleCheckLazyTest.java 59 List<Future<Object>> futures = executor.invokeAll(tasks); local
63 for (Future<Object> future : futures) {
  /tools/test/connectivity/acts/tests/google/ble/concurrency/
ConcurrentBleAdvertisingTest.py 90 except concurrent.futures._base.TimeoutError as error:
108 except concurrent.futures._base.TimeoutError as error:
509 except concurrent.futures._base.TimeoutError as error:
521 except concurrent.futures._base.TimeoutError as error:
564 except concurrent.futures._base.TimeoutError as error:
578 except concurrent.futures._base.TimeoutError as error:
593 except concurrent.futures._base.TimeoutError as error:
635 except concurrent.futures._base.TimeoutError as error:
650 except concurrent.futures._base.TimeoutError as error:
ConcurrentBleScanningTest.py 106 except concurrent.futures._base.TimeoutError as error:
202 except concurrent.futures._base.TimeoutError as error:
336 except concurrent.futures._base.TimeoutError as error:
  /tools/test/connectivity/acts/tests/google/ble/system_tests/
BleStressTest.py 169 except concurrent.futures._base.TimeoutError as error:
219 except concurrent.futures._base.TimeoutError as error:
238 except concurrent.futures._base.TimeoutError as error:
  /external/guava/guava-tests/test/com/google/common/eventbus/
EventBusTest.java 270 List<Future<?>> futures = Lists.newArrayList(); local
274 futures.add(executor.submit(new Registrator(bus, catchers)));
277 futures.get(i).get();
  /tools/test/connectivity/acts/framework/acts/
utils.py 18 import concurrent.futures namespace
274 with concurrent.futures.ThreadPoolExecutor(max_workers=30) as executor:
278 for future in concurrent.futures.as_completed(future_to_params):
  /external/guava/guava-tests/benchmark/com/google/common/collect/
ConcurrentHashMultisetBenchmark.java 90 List<Future<Long>> futures = Lists.newArrayListWithCapacity(threads);
92 futures.add(threadPool.submit(task));
95 for (Future<Long> future : futures) {

Completed in 597 milliseconds

1 2 3