| /external/cronet/tot/base/android/javatests/src/org/chromium/base/task/ |
| D | ChainedTasksTest.java | 49 final ChainedTasks tasks = new ChainedTasks(); in testCoalescedTasks() local
66 ChainedTasks tasks = new ChainedTasks(); in testCoalescedTasksDontBlockNonUiThread() local
98 ChainedTasks tasks = new ChainedTasks(); in testAsyncTasks() local
119 ChainedTasks tasks = new ChainedTasks(); in testAsyncTasksAreChained() local
152 ChainedTasks tasks = new ChainedTasks(); in testCanCancel() local
162 ChainedTasks tasks = new ChainedTasks(); in testUncaughtException() local
|
| /external/cronet/stable/base/android/javatests/src/org/chromium/base/task/ |
| D | ChainedTasksTest.java | 49 final ChainedTasks tasks = new ChainedTasks(); in testCoalescedTasks() local
66 ChainedTasks tasks = new ChainedTasks(); in testCoalescedTasksDontBlockNonUiThread() local
98 ChainedTasks tasks = new ChainedTasks(); in testAsyncTasks() local
119 ChainedTasks tasks = new ChainedTasks(); in testAsyncTasksAreChained() local
152 ChainedTasks tasks = new ChainedTasks(); in testCanCancel() local
162 ChainedTasks tasks = new ChainedTasks(); in testUncaughtException() local
|
| /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( in invokeAll()
113 public <T> T invokeAny(@Nonnull Collection<? extends Callable<T>> tasks) in invokeAny()
119 public <T> T invokeAny( in invokeAny()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/ |
| D | LimitingCoroutineDispatcherStressTest.kt | 24 val tasks = ArrayList<Deferred<*>>(iterations * 2) in <lambda>() constant
35 val tasks = ArrayList<Deferred<*>>(iterations * 2) in <lambda>() constant
|
| D | BlockingCoroutineDispatcherThreadLimitStressTest.kt | 26 val tasks = (1..iterations).map { in <lambda>() constant
45 val tasks = (1..iterations).map { in <lambda>() constant
|
| D | BlockingCoroutineDispatcherLivenessStressTest.kt | 29 val tasks = (1..2).map { in <lambda>() constant
49 val tasks = (1..2).map { in <lambda>() constant
|
| /external/pigweed/pw_async2/ |
| D | guides.rst | 172 .. _module-pw_async2-guides-tasks:
220 .. _module-pw_async2-guides-pendables:
273 .. _module-pw_async2-guides-pendables-complete:
280 .. _module-pw_async2-guides-passing-data:
322 .. _module-pw_async2-guides-coroutines:
|
| /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/connectedappssdk/sdk/src/main/java/com/google/android/enterprise/connectedapps/ |
| D | DebuggableScheduledExecutorService.java | 120 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
128 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
137 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
144 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
|
| /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 | 99 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
107 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
115 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
122 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 | 99 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
107 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
115 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
122 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
|
| /external/rust/android-crates-io/crates/tokio/src/runtime/ |
| D | dump.rs | 13 tasks: Tasks, field
21 tasks: Vec<Task>, field
49 pub fn tasks(&self) -> &Tasks { in tasks() method
|
| /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/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/rust/android-crates-io/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
|
| /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()
|