| /external/guava/guava-bootstrap/src/java/util/concurrent/ |
| D | ExecutorService.java | 34 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
38 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
41 <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
45 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
|
| D | AbstractExecutorService.java | 38 private <T> T doInvokeAny(Collection<? extends Callable<T>> tasks, in doInvokeAny()
104 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
114 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, in invokeAny()
120 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
150 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, in invokeAll()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingExecutorService.java | 55 Collection<? extends Callable<T>> tasks) throws InterruptedException { in invokeAll()
61 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
67 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
74 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny()
|
| D | ListeningExecutorService.java | 74 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
96 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | WrappingExecutorServiceTest.java | 96 List<Callable<String>> tasks = createTasks(3); in testInvokeAll() local
116 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()
300 Collection<? extends Callable<T>> tasks) { in assertTaskWrapped()
|
| D | WrappingScheduledExecutorServiceTest.java | 169 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
176 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
182 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
188 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 | 56 List<Runnable> tasks = executor.getTasks(); in testBasicDistribution() local
73 List<Runnable> tasks = Lists.newArrayList(); field in AsyncEventBusTest.FakeExecutor
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| D | SameThreadScheduledExecutorService.java | 101 Collection<? extends Callable<T>> tasks) throws InterruptedException { in invokeAll()
108 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll()
116 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny()
123 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, in invokeAny()
|
| /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/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/tensorflow/tensorflow/core/protobuf/ |
| D | cluster.proto | 76 map<int32, string> tasks = 2; field
|
| /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/gemmlowp/meta/ |
| D | multi_thread_gemm.h | 32 std::vector<Params>* tasks) { in PrepareGemmTask()
134 std::vector<Task*> tasks; in MultiThreadGemm() local
|
| D | legacy_multi_thread_common.h | 84 std::int32_t k, std::vector<internal::TaskRect>* tasks) { in PrepareTasks()
135 std::vector<Task*> tasks; in MultiThreadedMatrixMatrix() local
|
| /external/testng/src/main/java/org/testng/internal/ |
| D | PoolService.java | 40 public List<FutureType> submitTasksAndWait(List<? extends Callable<FutureType>> tasks) { in submitTasksAndWait()
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/ |
| D | ShadowActivityManager.java | 32 private final List<ActivityManager.RunningTaskInfo> tasks = new CopyOnWriteArrayList<>(); field in ShadowActivityManager
143 public void setTasks(List<ActivityManager.RunningTaskInfo> tasks) { in setTasks()
|
| /external/guava/guava-tests/test/com/google/common/cache/ |
| D | CacheLoaderTest.java | 40 private LinkedList<Runnable> tasks = Lists.newLinkedList(); field in CacheLoaderTest.QueuingExecutor
|
| /external/guice/extensions/service/src/com/google/inject/service/ |
| D | CompositeService.java | 93 final List<Future<State>> tasks = Lists.newArrayList(); in compose() local
|
| /external/swiftshader/third_party/subzero/pydir/ |
| D | wasm-run-torture-tests.py | 196 tasks = Queue.Queue() variable
|
| /external/dagger2/core/src/test/java/dagger/internal/ |
| D | DoubleCheckLazyTest.java | 49 List<Callable<Object>> tasks = Lists.newArrayListWithCapacity(numThreads); in get() local
|
| /external/toolchain-utils/bestflags/ |
| D | steering_test.py | 40 def __init__(self, tasks, next_generations): argument
|
| /external/libchrome/base/ |
| D | at_exit.cc | 77 base::stack<base::Closure> tasks; in ProcessCallbacksNow() local
|
| /external/ltp/testcases/kernel/sched/eas/ |
| D | eas_two_big_three_small.c | 111 pthread_t tasks[NUM_TASKS]; in run() local
|
| /external/smali/baksmali/src/main/java/org/jf/baksmali/ |
| D | Baksmali.java | 63 List<Future<Boolean>> tasks = Lists.newArrayList(); in disassembleDexFile() local
|
| /external/swiftshader/.vscode/ |
| D | tasks.json | 22 "tasks": [ array
|