/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...] |