| /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/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/tracing/ |
| D | PropagatedFluentFutures.java | 34 public static <T extends @Nullable Object> PropagatedFluentFuture<List<T>> allAsList( in allAsList()
41 PropagatedFluentFuture<List<@Nullable T>> successfulAsList( in successfulAsList()
|
| D | PropagatedFutures.java | 91 public static <V extends @Nullable Object> PropagatedFutureCombiner<V> whenAllComplete( in whenAllComplete()
97 Iterable<? extends ListenableFuture<? extends V>> futures) { in whenAllComplete()
102 public static <V extends @Nullable Object> PropagatedFutureCombiner<V> whenAllSucceed( in whenAllSucceed()
108 Iterable<? extends ListenableFuture<? extends V>> futures) { in whenAllSucceed()
|
| /external/rust/crates/tokio/src/macros/ |
| D | try_join.rs | 125 let mut futures = ( $( maybe_done($e), )* ); localVariable
131 let mut futures = &mut futures; localVariable
|
| D | join.rs | 79 let mut futures = ( $( maybe_done($e), )* ); localVariable
85 let mut futures = &mut futures; localVariable
|
| D | select.rs | 467 let mut futures = ( $( $fut , )+ ); localVariable
473 let mut futures = &mut futures; localVariable
|
| /external/apache-commons-lang/src/main/java/org/apache/commons/lang3/concurrent/ |
| D | UncheckedFuture.java | 48 static <T> Stream<UncheckedFuture<T>> map(final Collection<Future<T>> futures) { in map()
60 static <T> Collection<UncheckedFuture<T>> on(final Collection<Future<T>> futures) { in on()
|
| /external/mobile-data-download/java/com/google/android/libraries/mobiledatadownload/ |
| D | AggregateException.java | 65 Collection<ListenableFuture<T>> futures, in throwIfFailed()
101 Collection<ListenableFuture<T>> futures, String message, Object... args) in throwIfFailed()
117 Collection<ListenableFuture<T>> futures, String message, Object... args) { in consolidateDoneFutures()
|
| /external/mobile-data-download/javatests/com/google/android/libraries/mobiledatadownload/ |
| D | AggregateExceptionTest.java | 93 List<ListenableFuture<Void>> futures = new ArrayList<>(); in throwIfFailed_multipleExceptions() local
132 List<ListenableFuture<Void>> futures = new ArrayList<>(); in throwIfFailed_withCallback_invokesCallback() local
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | CollectionFuture.java | 42 ImmutableCollection<? extends ListenableFuture<? extends V>> futures, in CollectionFuture()
87 ImmutableCollection<? extends ListenableFuture<? extends V>> futures, in ListFuture()
|
| D | AggregateFuture.java | 59 @CheckForNull private ImmutableCollection<? extends ListenableFuture<? extends InputT>> futures; field in AggregateFuture
65 ImmutableCollection<? extends ListenableFuture<? extends InputT>> futures, in AggregateFuture()
|
| D | CombinedFuture.java | 39 ImmutableCollection<? extends ListenableFuture<?>> futures, in CombinedFuture()
49 ImmutableCollection<? extends ListenableFuture<?>> futures, in CombinedFuture()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | CollectionFuture.java | 42 ImmutableCollection<? extends ListenableFuture<? extends V>> futures, in CollectionFuture()
87 ImmutableCollection<? extends ListenableFuture<? extends V>> futures, in ListFuture()
|
| D | AggregateFuture.java | 59 @CheckForNull private ImmutableCollection<? extends ListenableFuture<? extends InputT>> futures; field in AggregateFuture
65 ImmutableCollection<? extends ListenableFuture<? extends InputT>> futures, in AggregateFuture()
|
| D | CombinedFuture.java | 39 ImmutableCollection<? extends ListenableFuture<?>> futures, in CombinedFuture()
49 ImmutableCollection<? extends ListenableFuture<?>> futures, in CombinedFuture()
|
| /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/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()
|
| D | AtomicLongMapBasherTest.java | 49 ArrayList<Future<Long>> futures = new ArrayList<>(); in testModify_basher() local
|
| /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()
|
| D | AtomicLongMapBasherTest.java | 49 ArrayList<Future<Long>> futures = new ArrayList<>(); in testModify_basher() 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/apache-commons-lang/src/test/java/org/apache/commons/lang3/builder/ |
| D | ReflectionToStringBuilderConcurrencyTest.java | 111 final List<Future<Integer>> futures = threadPool.invokeAll(tasks); in testConcurrency() local
|
| D | ToStringStyleConcurrencyTest.java | 103 final List<Future<Integer>> futures = threadPool.invokeAll(tasks); in testConcurrency() local
|
| /external/tensorflow/tensorflow/compiler/xla/python/ |
| D | py_executable.h | 54 explicit PyShardedToken(std::vector<PjRtFuture<Status>> futures) in PyShardedToken()
|