Home
last modified time | relevance | path

Searched refs:futures (Results 1 – 24 of 24) sorted by relevance

/external/guava/guava-bootstrap/src/java/util/concurrent/
DAbstractExecutorService.java46 List<Future<T>> futures= new ArrayList<Future<T>>(ntasks); in doInvokeAny() local
55 futures.add(ecs.submit(it.next())); in doInvokeAny()
64 futures.add(ecs.submit(it.next())); in doInvokeAny()
99 for (Future<T> f : futures) in doInvokeAny()
124 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); in invokeAll() local
129 futures.add(f); in invokeAll()
132 for (Future<T> f : futures) { in invokeAll()
142 return futures; in invokeAll()
145 for (Future<T> f : futures) in invokeAll()
156 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); in invokeAll() local
[all …]
/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/
DFuturesCombineBenchmark.java40 Iterable<? extends ListenableFuture<?>> futures) { in combine() argument
41 ListenableFuture<?> trigger = Futures.successfulAsList(futures); in combine()
60 Iterable<? extends ListenableFuture<?>> futures) {
61 return Futures.combine(combiner, executor, futures);
67 Iterable<? extends ListenableFuture<?>> futures);
84 ImmutableList<ListenableFuture<?>> futures = futuresBuilder.build();
89 sum += impl.combine(callable, INLINE_EXECUTOR, futures).get();
99 ImmutableList<ListenableFuture<?>> futures = futuresBuilder.build();
104 sum += impl.combine(callable, INLINE_EXECUTOR, futures).get();
114 ImmutableList<SettableFuture<Integer>> futures = getSettableFutureList();
[all …]
/external/guava/guava/src/com/google/common/util/concurrent/
DFutures.java1004 ListenableFuture<? extends V>... futures) {
1005 return listFuture(ImmutableList.copyOf(futures), true, directExecutor());
1026 Iterable<? extends ListenableFuture<? extends V>> futures) {
1027 return listFuture(ImmutableList.copyOf(futures), true, directExecutor());
1053 ImmutableList<ListenableFuture<?>> futures;
1055 CombinerFuture(Callable<V> callable, ImmutableList<ListenableFuture<?>> futures) {
1057 this.futures = futures;
1061 ImmutableList<ListenableFuture<?>> futures = this.futures;
1063 for (ListenableFuture<?> future : futures) {
1073 futures = null;
[all …]
DMoreExecutors.java678 List<Future<T>> futures = Lists.newArrayListWithCapacity(ntasks); in invokeAnyImpl() local
694 futures.add(submitAndAddQueueListener(executorService, it.next(), futureQueue)); in invokeAnyImpl()
703 futures.add(submitAndAddQueueListener(executorService, it.next(), futureQueue)); in invokeAnyImpl()
736 for (Future<T> f : futures) { in invokeAnyImpl()
/external/r8/src/main/java/com/android/tools/r8/dex/
DApplicationReader.java77 List<Future<?>> futures = new ArrayList<>(); in read() local
85 readProguardMap(builder, executorService, futures, closer); in read()
86 readMainDexList(builder, executorService, futures, closer); in read()
87 ClassReader classReader = new ClassReader(executorService, futures, closer); in read()
89 ThreadUtils.awaitFutures(futures); in read()
131 List<Future<?>> futures, Closer closer) in readProguardMap() argument
135 futures.add(executorService.submit(() -> { in readProguardMap()
147 List<Future<?>> futures, Closer closer) in readMainDexList() argument
150 futures.add(executorService.submit(() -> { in readMainDexList()
163 private final List<Future<?>> futures; field in ApplicationReader.ClassReader
[all …]
DVirtualFile.java411 ArrayList<Future<List<DexProgramClass>>> futures = new ArrayList<>(nameToFileMap.size()); in fillForDistribution() local
416 futures.add(executorService.submit(populator)); in fillForDistribution()
418 ThreadUtils.awaitFutures(futures).forEach(classes::removeAll); in fillForDistribution()
/external/r8/src/main/java/com/android/tools/r8/utils/
DThreadUtils.java15 public static <T> List<T> awaitFutures(List<? extends Future<? extends T>> futures) in awaitFutures() argument
17 ArrayList<T> result = new ArrayList<>(futures.size()); in awaitFutures()
18 for (Future<? extends T> f : futures) { in awaitFutures()
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DWrappingExecutorServiceTest.java100 List<Future<String>> futures = testExecutor.invokeAll(tasks); in testInvokeAll() local
102 checkResults(futures); in testInvokeAll()
109 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); in testInvokeAll() local
111 checkResults(futures); in testInvokeAll()
135 private static void checkResults(List<Future<String>> futures) in checkResults() argument
137 for (int i = 0; i < futures.size(); i++) { in checkResults()
138 assertEquals(RESULT_VALUE + i, futures.get(i).get()); in checkResults()
DFuturesTest.java848 List<ListenableFuture<String>> futures = ImmutableList.of();
849 ListenableFuture<List<String>> compound = Futures.allAsList(futures);
1491 List<ListenableFuture<String>> futures = ImmutableList.of();
1492 ListenableFuture<List<String>> compound = Futures.successfulAsList(futures);
2370 ImmutableList<ListenableFuture<Long>> futures = Futures.inCompletionOrder(
2379 for (ListenableFuture<Long> future : futures) {
2392 ImmutableList<ListenableFuture<Long>> futures = Futures.inCompletionOrder(
2401 for (ListenableFuture<Long> future : futures) {
2424 ImmutableList<ListenableFuture<Long>> futures = Futures.inCompletionOrder(
2433 for (ListenableFuture<Long> future : futures) {
[all …]
DMoreExecutorsTest.java154 List<Future<Integer>> futures = in testDirectExecutorServiceInvokeAll() local
158 Future<Integer> future = futures.get(i); in testDirectExecutorServiceInvokeAll()
266 List<ListenableFuture<T>> futures = (List) executor.invokeAll(tasks); in testListeningExecutorServiceInvokeAllJavadocCodeCompiles() local
/external/mockito/src/test/java/org/mockitousage/serialization/
DParallelSerializationTest.java33 List<Future<?>> futures = new ArrayList<Future<?>>(threadingFactor); in single_mock_being_serialized_in_different_classloaders_by_multiple_threads() local
41 futures.add(executorService.submit(new Callable<Object>() { in single_mock_being_serialized_in_different_classloaders_by_multiple_threads()
61 for (Future<?> future : futures) { in single_mock_being_serialized_in_different_classloaders_by_multiple_threads()
/external/guava/guava-tests/test/com/google/common/collect/
DConcurrentHashMultisetBasherTest.java72 List<Future<int[]>> futures = Lists.newArrayListWithExpectedSize(nTasks); in testAddAndRemove() local
74 futures.add(pool.submit(new MutateTask(multiset, keys))); in testAddAndRemove()
78 for (Future<int[]> future : futures) { in testAddAndRemove()
/external/dagger2/core/src/test/java/dagger/internal/
DDoubleCheckLazyTest.java59 List<Future<Object>> futures = executor.invokeAll(tasks); in get() local
63 for (Future<Object> future : futures) { in get()
/external/r8/src/main/java/com/android/tools/r8/ir/conversion/
DIRConverter.java230 List<Future<?>> futures = new ArrayList<>(); in convertClassesToDex() local
232 futures.add(executor.submit(() -> { in convertClassesToDex()
237 ThreadUtils.awaitFutures(futures); in convertClassesToDex()
287 List<Future<?>> futures = new ArrayList<>(); in optimize() local
289 futures.add(executorService.submit(() -> { in optimize()
294 ThreadUtils.awaitFutures(futures); in optimize()
/external/guava/guava-tests/test/com/google/common/eventbus/
DEventBusTest.java270 List<Future<?>> futures = Lists.newArrayList(); in testRegisterThreadSafety() local
274 futures.add(executor.submit(new Registrator(bus, catchers))); in testRegisterThreadSafety()
277 futures.get(i).get(); in testRegisterThreadSafety()
/external/guava/guava-tests/benchmark/com/google/common/collect/
DConcurrentHashMultisetBenchmark.java90 List<Future<Long>> futures = Lists.newArrayListWithCapacity(threads);
92 futures.add(threadPool.submit(task));
95 for (Future<Long> future : futures) {
/external/caliper/caliper/src/main/java/com/google/caliper/runner/
DExperimentingCaliperRun.java284 Iterable<? extends ListenableFuture<? extends T>> futures) { in inCompletionOrder() argument
287 for (final ListenableFuture<? extends T> future : futures) { in inCompletionOrder()
/external/r8/src/main/java/com/android/tools/r8/shaking/
DRootSetBuilder.java207 List<Future<?>> futures = new ArrayList<>(); in run() local
223 futures.add(executorService.submit(() -> { in run()
235 ThreadUtils.awaitFutures(futures); in run()
/external/python/cpython2/Lib/compiler/
Dpycodegen.py213 futures = self.get_module().futures
214 for feature in futures:
1302 self.futures = future.find_futures(tree)
1313 futures = () variable in ExpressionCodeGenerator
1328 futures = () variable in InteractiveCodeGenerator
/external/clang/test/
Dcxx-sections.data1481 30.6 [futures]
1482 30.6.1 [futures.overview]
1483 30.6.2 [futures.errors]
1484 30.6.3 [futures.future_error]
1485 30.6.4 [futures.promise]
1486 30.6.5 [futures.unique_future]
1488 30.6.7 [futures.task]
/external/llvm/utils/lit/
DTODO151 cost of implementing this is its impact on the API and futures changes.
/external/python/cpython2/Doc/library/
Dssl.rst1782 for example the :mod:`multiprocessing` or :mod:`concurrent.futures` modules),
/external/jline/src/src/test/resources/jline/example/
Denglish.gz
/external/icu/icu4j/main/shared/data/
DTransliterator_Han_Latin_Definition.txt5790 期貨 < futures\-\(on\-goods\);
27307 期貨 > futures\-\(on\-goods\);