| /external/jmdns/src/javax/jmdns/impl/tasks/ |
| package-info.java | 1 package javax.jmdns.impl.tasks;
|
| /external/jmdns/src/javax/jmdns/impl/tasks/resolver/ |
| package-info.java | 1 package javax.jmdns.impl.tasks.resolver;
|
| /external/jmdns/src/javax/jmdns/impl/tasks/state/ |
| package-info.java | 1 package javax.jmdns.impl.tasks.state;
|
| /external/chromium_org/chrome/browser/task_profiler/ |
| task_profiler_data_serializer_unittest.cc | 74 process_data.tasks.push_back(tracked_objects::TaskSnapshot());
75 process_data.tasks.back().birth = parent;
76 process_data.tasks.back().death_data.count = 37;
77 process_data.tasks.back().death_data.run_duration_max = 5;
78 process_data.tasks.back().death_data.run_duration_sample = 3;
79 process_data.tasks.back().death_data.run_duration_sum = 17;
80 process_data.tasks.back().death_data.queue_duration_max = 53;
81 process_data.tasks.back().death_data.queue_duration_sample = 13;
82 process_data.tasks.back().death_data.queue_duration_sum = 79;
83 process_data.tasks.back().death_thread_name = "WorkerPool/-1340960768"
[all...] |
| /packages/apps/QuickSearchBox/tests/src/com/android/quicksearchbox/util/ |
| MockTask.java | 70 public static void assertRanNever(String message, MockTask... tasks) {
71 for (MockTask task : tasks) {
76 public static void assertRanOnce(String message, MockTask... tasks) {
77 for (MockTask task : tasks) {
|
| /external/guava/guava-tests/test/com/google/common/eventbus/ |
| AsyncEventBusTest.java | 54 List<Runnable> tasks = executor.getTasks(); local
55 assertEquals("One event dispatch task should be queued.", 1, tasks.size());
57 tasks.get(0).run();
64 * An {@link Executor} wanna-be that simply records the tasks it's given.
71 List<Runnable> tasks = Lists.newArrayList(); field in class:AsyncEventBusTest.FakeExecutor
75 tasks.add(task);
79 return tasks;
|
| /external/chromium_org/chrome/browser/metrics/ |
| metrics_log_unittest.cc | 216 process_data.tasks.push_back(TaskSnapshot());
217 process_data.tasks.back().birth.location.file_name = "file";
218 process_data.tasks.back().birth.location.function_name = "function";
219 process_data.tasks.back().birth.location.line_number = 1337;
220 process_data.tasks.back().birth.thread_name = "birth_thread";
221 process_data.tasks.back().death_data.count = 37;
222 process_data.tasks.back().death_data.run_duration_sum = 31;
223 process_data.tasks.back().death_data.run_duration_max = 17;
224 process_data.tasks.back().death_data.run_duration_sample = 13;
225 process_data.tasks.back().death_data.queue_duration_sum = 8
[all...] |
| /external/robolectric/src/main/java/com/xtremelabs/robolectric/shadows/ |
| ShadowActivityManager.java | 17 private List<ActivityManager.RunningTaskInfo> tasks = field in class:ShadowActivityManager
28 return tasks;
49 * Non-Android accessor to set the list of running tasks.
50 * @param tasks
52 public void setTasks(List<ActivityManager.RunningTaskInfo> tasks) {
53 this.tasks = tasks;
|
| /external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/configuration/org.eclipse.osgi/bundles/46/1/.cp/lib/ |
| repository-tools-ant.jar | |
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| ForwardingExecutorService.java | 55 Collection<? extends Callable<T>> tasks) throws InterruptedException {
56 return delegate().invokeAll(tasks);
61 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
63 return delegate().invokeAll(tasks, timeout, unit);
67 public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
69 return delegate().invokeAny(tasks);
74 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
76 return delegate().invokeAny(tasks, timeout, unit);
|
| AbstractListeningExecutorService.java | 63 private <T> T doInvokeAny(Collection<? extends Callable<T>> tasks, boolean timed, long nanos)
65 int ntasks = tasks.size();
71 // parallelism, check to see if previously submitted tasks are
81 Iterator<? extends Callable<T>> it = tasks.iterator();
132 @Override public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
135 return doInvokeAny(tasks, false, 0);
142 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
144 return doInvokeAny(tasks, true, unit.toNanos(timeout));
147 @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
149 if (tasks == null)
[all...] |
| ListeningExecutorService.java | 62 * @return A list of {@code ListenableFuture} instances representing the tasks, in the same
69 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
77 * @return a list of {@code ListenableFuture} instances representing the tasks, in the same
80 * tasks will not have completed.
86 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
|
| /sdk/ |
| release.md | 6 gradle --init-script release.gradle <tasks
|
| /external/chromium_org/base/ |
| tracked_objects_unittest.cc | 66 ASSERT_EQ(1u, process_data.tasks.size());
68 EXPECT_EQ(kFile, process_data.tasks[0].birth.location.file_name);
70 process_data.tasks[0].birth.location.function_name);
71 EXPECT_EQ(kLineNumber, process_data.tasks[0].birth.location.line_number);
73 EXPECT_EQ(birth_thread, process_data.tasks[0].birth.thread_name);
75 EXPECT_EQ(count, process_data.tasks[0].death_data.count);
77 process_data.tasks[0].death_data.run_duration_sum);
78 EXPECT_EQ(run_ms, process_data.tasks[0].death_data.run_duration_max);
79 EXPECT_EQ(run_ms, process_data.tasks[0].death_data.run_duration_sample);
81 process_data.tasks[0].death_data.queue_duration_sum)
[all...] |
| /external/guava/guava-bootstrap/src/java/util/concurrent/ |
| ExecutorService.java | 34 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
38 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
41 <T> T invokeAny(Collection<? extends Callable<T>> tasks)
45 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| AbstractExecutorService.java | 110 private <T> T doInvokeAny(Collection<? extends Callable<T>> tasks,
113 if (tasks == null)
115 int ntasks = tasks.size();
123 // parallelism, check to see if previously submitted tasks are
133 Iterator<? extends Callable<T>> it = tasks.iterator();
181 public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
184 return doInvokeAny(tasks, false, 0);
191 public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
194 return doInvokeAny(tasks, true, unit.toNanos(timeout));
197 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
[all...] |
| ExecutorService.java | 18 * one or more asynchronous tasks.
21 * it to reject new tasks. Two different methods are provided for
23 * method will allow previously submitted tasks to execute before
25 * tasks from starting and attempts to stop currently executing tasks.
26 * Upon termination, an executor has no tasks actively executing, no
27 * tasks awaiting execution, and no new tasks can be submitted. An
36 * tasks and then waiting for at least one, or all, to
80 * first by calling {@code shutdown} to reject incoming tasks, and the
[all...] |
| /external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/configuration/org.eclipse.osgi/bundles/121/1/.cp/lib/ |
| apitooling-ant.jar | |
| /libcore/luni/src/main/java/java/util/ |
| Timer.java | 21 * Timers schedule one-shot or recurring {@link TimerTask tasks} for execution.
25 * <p>Each timer has one thread on which tasks are executed sequentially. When
26 * this thread is busy running a task, runnable tasks may be subject to delays.
31 * <p>Recurring tasks are scheduled with either a fixed period or a fixed rate:
41 * from starting tasks on time.
181 private TimerHeap tasks = new TimerHeap(); field in class:Timer.TimerImpl
208 if (tasks.isEmpty()) {
212 // no tasks scheduled -- sleep until any task appear
222 task = tasks.minimum();
227 tasks.delete(0)
[all...] |
| /external/chromium_org/gpu/command_buffer/service/ |
| async_pixel_transfer_manager_idle.cc | 106 shared_state_->tasks.push_back(AsyncPixelTransferManagerIdle::Task(
129 shared_state_->tasks.push_back(AsyncPixelTransferManagerIdle::Task(
149 shared_state_->tasks.begin();
150 iter != shared_state_->tasks.end();
156 shared_state_->tasks.erase(iter);
266 while (!tasks.empty()) {
268 if (tasks.front().transfer_id)
271 tasks.front().task.Run();
272 tasks.pop_front();
289 if (shared_state_.tasks.empty())
[all...] |
| /external/libmtp/examples/ |
| evolution-sync.sh | 65 cat $HOME/.evolution/tasks/local/system/tasks.ics \
|
| /frameworks/base/libs/hwui/thread/ |
| TaskManager.cpp | 82 Vector<TaskWrapper> tasks; local
85 tasks = mTasks;
89 for (size_t i = 0; i < tasks.size(); i++) {
90 const TaskWrapper& task = tasks.itemAt(i);
|
| /external/chromium_org/chrome/test/functional/media/ |
| worker_thread.py | 27 def RunWorkerThreads(pyauto_test, test_worker_class, tasks, num_threads,
29 """Creates a matrix of tasks and starts test worker threads to run them.
34 tasks: Queue of tasks to run by the worker threads.
43 tasks.put(None)
47 threads.append(test_worker_class(pyauto_test, tasks, test_url))
62 def __init__(self, pyauto_test, tasks, url):
67 tasks: Queue containing task tuples used by RunTest().
72 self.__tasks = tasks
|
| /packages/apps/Dialer/tests/src/com/android/dialer/util/ |
| FakeAsyncTaskExecutor.java | 42 * Tasks submitted to this executor will not be run immediately. Rather they will be stored in a
43 * list of submitted tasks, where they can be examined. They can also be run on-demand using the run
53 /** The maximum length of time in ms to wait for tasks to execute during tests. */
149 * Removes the matching task from the list of submitted tasks, then runs it. The executor used
157 List<SubmittedTask> tasks = getSubmittedTasksByIdentifier(identifier, true); local
158 Assert.assertEquals("Expected one task " + identifier + ", got " + tasks, 1, tasks.size());
159 runTask(tasks.get(0));
163 * Runs all tasks whose identifier matches the given identifier.
165 * Removes all matching tasks from the list of submitted tasks, and runs them. The executor use
173 List<SubmittedTask> tasks = getSubmittedTasksByIdentifier(identifier, true); local
[all...] |
| /external/chromium_org/chrome/browser/resources/task_manager/ |
| preload.js | 11 * @param {Integer} start The start position of tasks to be changed
12 * @param {Integer} length The length of tasks to be changed
13 * @param {Array of task} tasks The array of updated task
15 function taskChanged(start, length, tasks) {
16 var task = {type: 'change', start: start, length: length, tasks: tasks};
|
