| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingExecutorService.java | 56 Collection<? extends Callable<T>> tasks) throws InterruptedException { in invokeAll()
62 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
68 public <T extends @Nullable Object> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
75 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/guava/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingExecutorService.java | 56 Collection<? extends Callable<T>> tasks) throws InterruptedException { in invokeAll()
62 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
68 public <T extends @Nullable Object> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
75 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()
|
| D | WrappingScheduledExecutorServiceTest.java | 181 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
188 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
194 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
200 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
|
| /external/guava/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()
|
| D | WrappingScheduledExecutorServiceTest.java | 181 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
188 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
194 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
200 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 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/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/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/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | FakeClock.java | 53 private final PriorityBlockingQueue<ScheduledTask> tasks = field in FakeClock
137 @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) { in invokeAll()
142 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) { in invokeAll()
146 @Override public <T> T invokeAny(Collection<? extends Callable<T>> tasks) { in invokeAny()
151 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) { in invokeAny()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/coordination/ |
| D | coordination_service_barrier_proxy_test.cc | 117 const std::vector<CoordinatedTask> tasks(num_tasks); in TestBarrierProxyWait() local
203 const std::vector<CoordinatedTask> tasks; in TestBarrierProxyManagerWaitSingleKey() local
262 const std::vector<CoordinatedTask> tasks; in TEST() local
|
| /external/vogar/src/vogar/tasks/ |
| D | TaskQueue.java | 39 private final LinkedList<Task> tasks = new LinkedList<Task>(); field in TaskQueue
56 public void enqueueAll(Collection<Task> tasks) { in enqueueAll()
|
| /external/grpc-grpc-java/android/src/test/java/io/grpc/android/ |
| D | AndroidChannelBuilderTest.java | 444 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) { in invokeAll()
450 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) { in invokeAll()
455 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) { in invokeAny()
460 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) { in invokeAny()
|
| /external/tensorflow/tensorflow/core/data/service/ |
| D | dispatcher_state_test.cc | 454 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
459 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
477 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
497 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
502 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
520 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
539 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
544 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
555 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
|