Home
last modified time | relevance | path

Searched defs:tasks (Results 1 – 25 of 101) sorted by relevance

12345

/external/guava/android/guava/src/com/google/common/util/concurrent/
DForwardingExecutorService.java53 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()
DListeningExecutorService.java76 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
100 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
/external/guava/guava/src/com/google/common/util/concurrent/
DForwardingExecutorService.java53 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()
DListeningExecutorService.java76 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
100 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/scheduling/
DLimitingCoroutineDispatcherStressTest.kt27 val tasks = ArrayList<Deferred<*>>(iterations * 2) in <lambda>() constant
38 val tasks = ArrayList<Deferred<*>>(iterations * 2) in <lambda>() constant
DBlockingCoroutineDispatcherRaceStressTest.kt26 val tasks = (1..2).map { in <lambda>() constant
49 val tasks = (1..2).map { in <lambda>() constant
DBlockingCoroutineDispatcherStressTest.kt27 val tasks = (1..iterations).map { in <lambda>() constant
98 val tasks = (1..blockingLimit).map { async(blocking) { barrier.await() } } in <lambda>() constant
118 val tasks = (1..blockingLimit).map { async(blocking) { barrier.await() } } in <lambda>() constant
DLimitingDispatcherTest.kt34 val tasks = ArrayList<Job>(6) in testBlockingInterleave() constant
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DWrappingExecutorServiceTest.java95 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()
DWrappingScheduledExecutorServiceTest.java181 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/android/guava-tests/test/com/google/common/util/concurrent/
DWrappingExecutorServiceTest.java95 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()
DWrappingScheduledExecutorServiceTest.java181 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/android/guava-tests/test/com/google/common/eventbus/
DAsyncEventBusTest.java55 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/
DAsyncEventBusTest.java55 List<Runnable> tasks = executor.getTasks(); in testBasicDistribution() local
71 List<Runnable> tasks = Lists.newArrayList(); field in AsyncEventBusTest.FakeExecutor
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/
DSameThreadScheduledExecutorService.java98 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/
DSameThreadScheduledExecutorService.java98 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/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DFakeClock.java53 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/protobuf/
Dcluster.proto76 map<int32, string> tasks = 2; field
Ddevice_filters.proto68 map<int32, TaskDeviceFilters> tasks = 2; field
/external/tensorflow/tensorflow/lite/kernels/
Dcpu_backend_threadpool.h37 void Execute(int tasks_count, TaskType* tasks, in Execute()
/external/vogar/src/vogar/tasks/
DTaskQueue.java39 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/
DAndroidChannelBuilderTest.java444 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/delegates/gpu/metal/kernels/
Dcustom_registry.cc33 std::vector<ComputeTaskDescriptorPtr>* tasks) { in RegisterCustomOps()
/external/tensorflow/tensorflow/lite/experimental/ruy/
Dthread_pool.h75 void Execute(int task_count, TaskType* tasks) { in Execute()
/external/testng/src/main/java/org/testng/internal/
DPoolService.java40 public List<FutureType> submitTasksAndWait(List<? extends Callable<FutureType>> tasks) { in submitTasksAndWait()

12345