| /external/okio/okio/src/jvmTest/kotlin/okio/ |
| D | ThrottlerTest.kt | 88 val futures = List(threads) { in parallel() constant
101 val futures = List(threads) { in parallelFastThenSlower() constant
116 val futures = List(threads) { in parallelSlowThenFaster() constant
131 val futures = List(threads) { in parallelIndividualThrottle() constant
147 val futures = List(threads) { in parallelGroupAndIndividualThrottle() constant
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | CollectionFuture.java | 40 ImmutableCollection<? extends ListenableFuture<? extends V>> futures, in CollectionFuture()
84 ImmutableCollection<? extends ListenableFuture<? extends V>> futures, in ListFuture()
|
| D | AggregateFuture.java | 55 @NullableDecl private ImmutableCollection<? extends ListenableFuture<? extends InputT>> futures; field in AggregateFuture
61 ImmutableCollection<? extends ListenableFuture<? extends InputT>> futures, in AggregateFuture()
|
| D | CombinedFuture.java | 36 ImmutableCollection<? extends ListenableFuture<?>> futures, in CombinedFuture()
46 ImmutableCollection<? extends ListenableFuture<?>> futures, in CombinedFuture()
|
| D | ClosingFuture.java | 431 public static Combiner whenAllComplete(Iterable<? extends ClosingFuture<?>> futures) { in whenAllComplete()
453 public static Combiner whenAllSucceed(Iterable<? extends ClosingFuture<?>> futures) { in whenAllSucceed()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | CollectionFuture.java | 40 ImmutableCollection<? extends ListenableFuture<? extends V>> futures, in CollectionFuture()
84 ImmutableCollection<? extends ListenableFuture<? extends V>> futures, in ListFuture()
|
| D | AggregateFuture.java | 55 private @Nullable ImmutableCollection<? extends ListenableFuture<? extends InputT>> futures; field in AggregateFuture
61 ImmutableCollection<? extends ListenableFuture<? extends InputT>> futures, in AggregateFuture()
|
| D | CombinedFuture.java | 36 ImmutableCollection<? extends ListenableFuture<?>> futures, in CombinedFuture()
46 ImmutableCollection<? extends ListenableFuture<?>> futures, in CombinedFuture()
|
| D | ClosingFuture.java | 430 public static Combiner whenAllComplete(Iterable<? extends ClosingFuture<?>> futures) { in whenAllComplete()
452 public static Combiner whenAllSucceed(Iterable<? extends ClosingFuture<?>> futures) { in whenAllSucceed()
|
| /external/rust/crates/tokio/src/macros/ |
| D | join.rs | 72 let mut futures = ( $( maybe_done($e), )* ); localVariable
|
| D | try_join.rs | 79 let mut futures = ( $( maybe_done($e), )* ); localVariable
|
| D | select.rs | 411 let mut futures = ( $( $fut , )+ ); localVariable
|
| /external/jimfs/jimfs/src/test/java/com/google/common/jimfs/ |
| D | JimfsFileChannelTest.java | 681 List<Future<?>> futures = queueAllBlockingOperations(channel, executor, latch); in testAsynchronousClose() local
744 List<Future<?>> futures = queueAllBlockingOperations(channel, executor, blockingStartLatch); in testCloseByInterrupt() local
784 List<Future<?>> futures = new ArrayList<>(); in queueAllBlockingOperations() local
|
| /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/java/dagger/producers/internal/ |
| D | DependencyMethodProducer.java | 41 private final Set<ListenableFuture<T>> futures = field in DependencyMethodProducer
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | WrappingExecutorServiceTest.java | 99 List<Future<String>> futures = testExecutor.invokeAll(tasks); in testInvokeAll() local
108 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); in testInvokeAll() local
134 private static void checkResults(List<Future<String>> futures) in checkResults()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | WrappingExecutorServiceTest.java | 99 List<Future<String>> futures = testExecutor.invokeAll(tasks); in testInvokeAll() local
108 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); in testInvokeAll() local
134 private static void checkResults(List<Future<String>> futures) in checkResults()
|
| /external/jackson-core/src/test/java/com/fasterxml/jackson/core/json/async/ |
| D | AsyncConcurrencyTest.java | 125 ArrayList<Future<?>> futures = new ArrayList<Future<?>>(); in _testConcurrentAsyncOnce() 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/guice/core/test/com/google/inject/internal/ |
| D | CycleDetectingLockTest.java | 200 ImmutableList<Future<ListMultimap<Thread, String>>> futures = in testCycleReporting() local
|
| /external/python/setuptools/setuptools/tests/ |
| D | test_build_meta.py | 9 futures = pytest.importorskip('concurrent.futures') variable
|
| /external/dagger2/javatests/dagger/internal/ |
| D | DoubleCheckTest.java | 93 List<Future<Object>> futures = executor.invokeAll(tasks); in get() local
|
| /external/guava/android/guava-tests/test/com/google/common/graph/ |
| D | ValueGraphTest.java | 393 ImmutableList.Builder<Future<?>> futures = ImmutableList.builder(); in concurrentIteration() local
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | ConcurrentHashMultisetBasherTest.java | 70 List<Future<int[]>> futures = Lists.newArrayListWithExpectedSize(nTasks); in testAddAndRemove() local
|
| /external/guava/android/guava-tests/test/com/google/common/collect/ |
| D | ConcurrentHashMultisetBasherTest.java | 70 List<Future<int[]>> futures = Lists.newArrayListWithExpectedSize(nTasks); in testAddAndRemove() local
|