| /external/guava/android/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingExecutorService.java | 53 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
60 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
66 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
72 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
|
| D | ListeningExecutorService.java | 80 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
104 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingExecutorService.java | 53 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
60 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
66 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
72 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
|
| D | ListeningExecutorService.java | 80 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
104 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
|
| /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 | 34 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/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/rust/crates/futures/tests/ |
| D | futures_unordered.rs | 16 let mut tasks = FuturesUnordered::new(); in is_terminated() localVariable
360 let mut tasks = FuturesUnordered::from_iter(vec![F::default(); 10]); in polled_only_once_at_most_per_iteration() localVariable
364 let mut tasks = FuturesUnordered::from_iter(vec![F::default(); 33]); in polled_only_once_at_most_per_iteration() localVariable
368 let mut tasks = FuturesUnordered::<F>::new(); in polled_only_once_at_most_per_iteration() localVariable
|
| /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/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/data/service/ |
| D | dispatcher_state_test.cc | 222 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
279 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
284 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
302 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
322 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
327 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
345 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
364 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
369 std::vector<std::shared_ptr<const Task>> tasks; in TEST() local
380 std::vector<std::shared_ptr<const Task>> 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/lite/kernels/ |
| D | cpu_backend_threadpool.h | 37 void Execute(int tasks_count, TaskType* tasks, in Execute()
|
| /external/tensorflow/tensorflow/core/protobuf/ |
| D | cluster.proto | 77 map<int32, string> tasks = 2; field
|
| D | device_filters.proto | 67 map<int32, TaskDeviceFilters> tasks = 2; field
|