| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ListeningExecutorService.java | 89 <T extends @Nullable Object> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
113 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
123 Collection<? extends Callable<T>> tasks, Duration timeout) throws InterruptedException { in invokeAll()
134 Collection<? extends Callable<T>> tasks, Duration timeout) in invokeAny()
|
| D | ForwardingExecutorService.java | 63 Collection<? extends Callable<T>> tasks) throws InterruptedException { in invokeAll()
69 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
75 public <T extends @Nullable Object> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
82 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | ListeningExecutorServiceTest.java | 45 Set<Callable<String>> tasks = Collections.singleton(() -> "invokeAny"); in testInvokeAny() local
56 Set<Callable<String>> tasks = Collections.singleton(() -> "invokeAll"); in testInvokeAll() local
77 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
91 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
|
| D | WrappingExecutorServiceTest.java | 95 List<Callable<String>> tasks = createTasks(3); in testInvokeAll() local
115 List<Callable<String>> tasks = createTasks(3); in testInvokeAny() local
213 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
222 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
232 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
240 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
299 private static <T> void assertTaskWrapped(Collection<? extends Callable<T>> tasks) { in assertTaskWrapped()
|
| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingExecutorService.java | 63 Collection<? extends Callable<T>> tasks) throws InterruptedException { in invokeAll()
69 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
75 public <T extends @Nullable Object> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
82 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
|
| D | ListeningExecutorService.java | 83 <T extends @Nullable Object> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
107 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
|
| /external/robolectric/shadows/framework/src/main/java/org/robolectric/android/util/concurrent/ |
| D | InlineExecutorService.java | 98 public <T> List<Future<T>> invokeAll(@NonNull Collection<? extends Callable<T>> tasks) in invokeAll()
105 public <T> List<Future<T>> invokeAll(@NonNull Collection<? extends Callable<T>> tasks, in invokeAll()
112 public <T> T invokeAny(@NonNull Collection<? extends Callable<T>> tasks) in invokeAny()
118 public <T> T invokeAny(@NonNull Collection<? extends Callable<T>> tasks, long timeout, in invokeAny()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | LimitingCoroutineDispatcherStressTest.kt | 27 val tasks = ArrayList<Deferred<*>>(iterations * 2) in <lambda>() constant
38 val tasks = ArrayList<Deferred<*>>(iterations * 2) in <lambda>() constant
|
| D | BlockingCoroutineDispatcherLivenessStressTest.kt | 32 val tasks = (1..2).map { in <lambda>() constant
52 val tasks = (1..2).map { in <lambda>() constant
|
| D | BlockingCoroutineDispatcherThreadLimitStressTest.kt | 29 val tasks = (1..iterations).map { in <lambda>() constant
53 val tasks = (1..iterations).map { in <lambda>() constant
|
| D | BlockingCoroutineDispatcherWorkSignallingStressTest.kt | 73 val tasks = (1..blockingLimit).map { async(blocking) { barrier.await() } } in <lambda>() constant
91 val tasks = (1..blockingLimit).map { async(blocking) { barrier.await() } } in <lambda>() constant
|
| D | LimitingDispatcherTest.kt | 29 val tasks = ArrayList<Job>(6) in testBlockingInterleave() constant
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | WrappingExecutorServiceTest.java | 95 List<Callable<String>> tasks = createTasks(3); in testInvokeAll() local
115 List<Callable<String>> tasks = createTasks(3); in testInvokeAny() local
213 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
222 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
232 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
240 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
299 private static <T> void assertTaskWrapped(Collection<? extends Callable<T>> tasks) { in assertTaskWrapped()
|
| /external/aws-sdk-java-v2/codegen/src/main/java/software/amazon/awssdk/codegen/emitters/tasks/ |
| D | CompositeGeneratorTask.java | 22 private final GeneratorTask[] tasks; field in CompositeGeneratorTask
24 protected CompositeGeneratorTask(GeneratorTask... tasks) { in CompositeGeneratorTask()
|
| /external/aws-sdk-java-v2/core/aws-core/src/test/java/software/amazon/awssdk/awscore/util/ |
| D | TestWrapperSchedulerService.java | 103 …public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedEx… in invokeAll()
108 …public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUn… in invokeAll()
113 …public <T> T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, Execu… in invokeAny()
118 …public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throw… in invokeAny()
|
| /external/rust/crates/futures/tests/ |
| D | stream_futures_unordered.rs | 16 let mut tasks = FuturesUnordered::new(); in is_terminated() localVariable
351 let mut tasks = FuturesUnordered::from_iter(vec![F::default(); 10]); in polled_only_once_at_most_per_iteration() localVariable
355 let mut tasks = FuturesUnordered::from_iter(vec![F::default(); 33]); in polled_only_once_at_most_per_iteration() localVariable
359 let mut tasks = FuturesUnordered::<F>::new(); in polled_only_once_at_most_per_iteration() localVariable
365 let mut tasks = FuturesUnordered::from_iter(vec![future::ready(1), future::ready(2)]); in clear() localVariable
|
| D | stream_select_all.rs | 11 let mut tasks = SelectAll::new(); in is_terminated() localVariable
82 let mut tasks = in clear() localVariable
|
| /external/rust/crates/tokio/src/runtime/ |
| D | dump.rs | 12 tasks: Tasks, field
20 tasks: Vec<Task>, field
47 pub fn tasks(&self) -> &Tasks { in tasks() method
|
| /external/aws-sdk-java-v2/utils/src/main/java/software/amazon/awssdk/utils/ |
| D | ScheduledExecutorUtils.java | 146 …public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedEx… in invokeAll()
151 …public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUn… in invokeAll()
157 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
163 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | SameThreadScheduledExecutorService.java | 98 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
106 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
114 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
121 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
|
| /external/guava/android/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | SameThreadScheduledExecutorService.java | 98 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
106 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
114 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
121 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
|
| /external/guava/guava-tests/test/com/google/common/eventbus/ |
| D | AsyncEventBusTest.java | 55 List<Runnable> tasks = executor.getTasks(); in testBasicDistribution() local
71 List<Runnable> tasks = Lists.newArrayList(); field in AsyncEventBusTest.FakeExecutor
|
| /external/guava/android/guava-tests/test/com/google/common/eventbus/ |
| D | AsyncEventBusTest.java | 55 List<Runnable> tasks = executor.getTasks(); in testBasicDistribution() local
71 List<Runnable> tasks = Lists.newArrayList(); field in AsyncEventBusTest.FakeExecutor
|
| /external/rust/crates/tokio/tests/ |
| D | dump.rs | 39 let tasks: Vec<_> = dump.tasks().iter().collect(); in current_thread() localVariable
76 let tasks: Vec<_> = dump.tasks().iter().collect(); in multi_thread() localVariable
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/ |
| D | DelegatingEventLoopGroup.java | 118 …ublic <T> List<java.util.concurrent.Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) … in invokeAll()
124 …ublic <T> List<java.util.concurrent.Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, … in invokeAll()
130 …public <T> T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, Execu… in invokeAny()
135 …public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throw… in invokeAny()
|