| /external/guava/guava-bootstrap/src/java/util/concurrent/ |
| D | AbstractExecutorService.java | 46 List<Future<T>> futures= new ArrayList<Future<T>>(ntasks); in doInvokeAny() local
124 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); in invokeAll() local
156 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); in invokeAll() local
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | FuturesCombineBenchmark.java | 40 Iterable<? extends ListenableFuture<?>> futures) { in combine()
|
| /external/mockito/src/test/java/org/mockitousage/serialization/ |
| D | ParallelSerializationTest.java | 33 List<Future<?>> futures = new ArrayList<Future<?>>(threadingFactor); in single_mock_being_serialized_in_different_classloaders_by_multiple_threads() local
|
| /external/dagger2/core/src/test/java/dagger/internal/ |
| D | DoubleCheckLazyTest.java | 59 List<Future<Object>> futures = executor.invokeAll(tasks); in get() local
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | WrappingExecutorServiceTest.java | 100 List<Future<String>> futures = testExecutor.invokeAll(tasks); in testInvokeAll() local
109 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); in testInvokeAll() local
135 private static void checkResults(List<Future<String>> futures) in checkResults()
|
| D | MoreExecutorsTest.java | 154 List<Future<Integer>> futures = in testDirectExecutorServiceInvokeAll() local
266 List<ListenableFuture<T>> futures = (List) executor.invokeAll(tasks); in testListeningExecutorServiceInvokeAllJavadocCodeCompiles() local
|
| /external/guice/core/test/com/google/inject/internal/ |
| D | CycleDetectingLockTest.java | 200 ImmutableList<Future<ListMultimap<Thread, String>>> futures = in testCycleReporting() local
|
| /external/apache-commons-compress/src/main/java/org/apache/commons/compress/archivers/zip/ |
| D | ParallelScatterZipCreator.java | 58 private final List<Future<Object>> futures = new ArrayList<>(); field in ParallelScatterZipCreator
|
| /external/python/setuptools/setuptools/tests/ |
| D | test_build_meta.py | 9 futures = pytest.importorskip('concurrent.futures') variable
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | ConcurrentHashMultisetBasherTest.java | 72 List<Future<int[]>> futures = Lists.newArrayListWithExpectedSize(nTasks); in testAddAndRemove() local
|
| /external/caliper/caliper/src/main/java/com/google/caliper/runner/ |
| D | ExperimentingCaliperRun.java | 284 Iterable<? extends ListenableFuture<? extends T>> futures) { in inCompletionOrder()
|
| /external/guava/guava-tests/test/com/google/common/eventbus/ |
| D | EventBusTest.java | 270 List<Future<?>> futures = Lists.newArrayList(); in testRegisterThreadSafety() local
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/ |
| D | AsyncClient.java | 124 List<Future<Histogram>> futures = in doBenchmark() local
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| D | _base.py | 141 def __init__(self, futures): argument
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | MoreExecutors.java | 678 List<Future<T>> futures = Lists.newArrayListWithCapacity(ntasks); in invokeAnyImpl() local
|
| /external/python/futures/concurrent/futures/ |
| D | _base.py | 143 def __init__(self, futures): argument
|
| /external/python/cpython2/Lib/compiler/ |
| D | pycodegen.py | 1313 futures = () variable in ExpressionCodeGenerator
1328 futures = () variable in InteractiveCodeGenerator
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_tasks.py | 2914 def wrap_futures(self, *futures):
3002 def wrap_futures(self, *futures):
|
| /external/conscrypt/repackaged/openjdk-integ-tests/src/test/java/com/android/org/conscrypt/java/security/ |
| D | SignatureTest.java | 3044 List<Future<Void>> futures = new ArrayList<Future<Void>>(); in testSignature_MultipleThreads_Misuse() local
|
| /external/conscrypt/openjdk-integ-tests/src/test/java/org/conscrypt/java/security/ |
| D | SignatureTest.java | 3040 List<Future<Void>> futures = new ArrayList<Future<Void>>(); in testSignature_MultipleThreads_Misuse() local
|