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

1 2

  /libcore/luni/src/main/java/java/util/concurrent/
AbstractExecutorService.java 119 ArrayList<Future<T>> futures = new ArrayList<Future<T>>(ntasks); local
137 futures.add(ecs.submit(it.next()));
146 futures.add(ecs.submit(it.next()));
177 for (int i = 0, size = futures.size(); i < size; i++)
178 futures.get(i).cancel(true);
202 ArrayList<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); local
207 futures.add(f);
210 for (int i = 0, size = futures.size(); i < size; i++) {
211 Future<T> f = futures.get(i);
221 return futures;
235 ArrayList<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); local
    [all...]
ForkJoinPool.java 91 * <td> {@link ForkJoinTask#fork} (ForkJoinTasks <em>are</em> Futures)</td>
393 * efficient futures" SIGPLAN Notices, 1993
2580 ArrayList<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); local
    [all...]
  /external/guava/guava/src/com/google/common/util/concurrent/
AbstractListeningExecutorService.java 90 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); local
95 futures.add(f);
98 for (Future<T> f : futures) {
106 return futures;
109 for (Future<T> f : futures) {
123 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); local
127 futures.add(ListenableFutureTask.create(t));
134 Iterator<Future<T>> it = futures.iterator();
141 return futures;
145 for (Future<T> f : futures) {
    [all...]
Futures.java 73 public final class Futures {
74 private Futures() {}
319 * ListenableFuture<Integer> faultTolerantFuture = Futures.withFallback(
336 * ListenableFuture<Integer> faultTolerantFuture = Futures.withFallback(
397 * ListenableFuture<Integer> faultTolerantFuture = Futures.withFallback(
414 * ListenableFuture<Integer> faultTolerantFuture = Futures.withFallback(
798 * exception types. The reason for this is that {@code Futures.transform} used
800 * throw checked exceptions. Nowadays, {@code Futures.transform} has an
    [all...]
MoreExecutors.java 612 List<Future<T>> futures = Lists.newArrayListWithCapacity(ntasks); local
628 futures.add(submitAndAddQueueListener(executorService, it.next(), futureQueue));
637 futures.add(submitAndAddQueueListener(executorService, it.next(), futureQueue));
670 for (Future<T> f : futures) {
    [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...]
  /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...]
  /libcore/jsr166-tests/src/test/java/jsr166/
AbstractExecutorServiceTest.java 377 List<Future<String>> futures = e.invokeAll(l); local
378 assertEquals(1, futures.size());
380 futures.get(0).get();
399 List<Future<String>> futures = e.invokeAll(l); local
400 assertEquals(2, futures.size());
401 for (Future<String> future : futures)
571 List<Future<String>> futures = local
573 assertEquals(1, futures.size());
575 futures.get(0).get();
594 List<Future<String>> futures local
614 List<Future<String>> futures = local
    [all...]
ScheduledExecutorTest.java 963 List<Future<String>> futures = e.invokeAll(l); local
984 List<Future<String>> futures = e.invokeAll(l); local
1156 List<Future<String>> futures = local
1178 List<Future<String>> futures = local
1198 List<Future<String>> futures = local
    [all...]
ScheduledExecutorSubclassTest.java 1017 List<Future<String>> futures = e.invokeAll(l); local
1038 List<Future<String>> futures = e.invokeAll(l); local
1210 List<Future<String>> futures = local
1232 List<Future<String>> futures = local
1252 List<Future<String>> futures = local
    [all...]
ForkJoinPoolTest.java 775 List<Future<String>> futures = e.invokeAll(l); local
776 assertEquals(1, futures.size());
778 futures.get(0).get();
796 List<Future<String>> futures = e.invokeAll(l); local
797 assertEquals(2, futures.size());
798 for (Future<String> future : futures)
971 List<Future<String>> futures local
973 assertEquals(1, futures.size());
975 futures.get(0).get();
993 List<Future<String>> futures local
    [all...]
ThreadPoolExecutorSubclassTest.java 1464 List<Future<String>> futures = e.invokeAll(l); local
1485 List<Future<String>> futures = e.invokeAll(l); local
1657 List<Future<String>> futures = local
1679 List<Future<String>> futures = local
1699 List<Future<String>> futures = local
    [all...]
ThreadPoolExecutorTest.java 1626 List<Future<String>> futures = e.invokeAll(l); local
1651 List<Future<String>> futures = e.invokeAll(l); local
1856 List<Future<String>> futures = local
1881 List<Future<String>> futures = local
1904 List<Future<String>> futures = local
    [all...]
FutureTaskTest.java 825 final List<Future<?>> futures = new ArrayList<>(); local
834 futures.add(pool.submit(r));
837 for (Future<?> future : futures)
  /external/guava/guava-tests/test/com/google/common/util/concurrent/
WrappingExecutorServiceTest.java 103 List<Future<String>> futures = testExecutor.invokeAll(tasks); local
105 checkResults(futures);
112 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); local
114 checkResults(futures);
138 private static void checkResults(List<Future<String>> futures)
140 for (int i = 0; i < futures.size(); i++) {
141 assertEquals(RESULT_VALUE + i, futures.get(i).get());
FuturesTest.java 20 import static com.google.common.util.concurrent.Futures.allAsList;
21 import static com.google.common.util.concurrent.Futures.get;
22 import static com.google.common.util.concurrent.Futures.getUnchecked;
23 import static com.google.common.util.concurrent.Futures.immediateFailedFuture;
24 import static com.google.common.util.concurrent.Futures.immediateFuture;
25 import static com.google.common.util.concurrent.Futures.successfulAsList;
72 * Unit tests for {@link Futures}.
74 * TODO: Add tests for other Futures methods
80 "com.google.common.util.concurrent.Futures$CombinedFuture");
108 ListenableFuture<String> future = Futures.immediateFuture(DATA1)
    [all...]
MoreExecutorsTest.java 154 List<Future<Integer>> futures = local
158 Future<Integer> future = futures.get(i);
266 List<ListenableFuture<T>> futures = (List) executor.invokeAll(tasks); local
  /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 67 List<Future<int[]>> futures = Lists.newArrayListWithExpectedSize(nTasks); local
69 futures.add(pool.submit(new MutateTask(multiset, keys)));
73 for (Future<int[]> future : futures) {
  /external/guava/guava-tests/test/com/google/common/eventbus/
EventBusTest.java 269 List<Future<?>> futures = Lists.newArrayList(); local
273 futures.add(executor.submit(new Registrator(bus, catchers)));
276 futures.get(i).get();
  /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) {
  /ndk/tests/device/test-libc++-shared-full/jni/
Android.mk     [all...]
  /ndk/tests/device/test-libc++-static-full/jni/
Android.mk     [all...]
  /external/chromium-trace/trace-viewer/perf_insights/third_party/cloudstorage/
storage_api.py 407 futures = []
410 futures.append(self._get_segment(start, self._max_request_size))
414 futures.append(self._get_segment(start, end-start))
415 return [fut.get_result() for fut in futures]
  /prebuilts/python/darwin-x86/2.7.5/lib/python2.7/compiler/
pycodegen.py 213 futures = self.get_module().futures
214 for feature in futures:
1313 futures = () variable in class:ExpressionCodeGenerator
1328 futures = () variable in class:InteractiveCodeGenerator
    [all...]

Completed in 1154 milliseconds

1 2