| /libcore/luni/src/main/java/java/util/concurrent/ |
| Executor.java | 10 * An object that executes submitted {@link Runnable} tasks. This
16 * of a set of tasks, you might use:
37 * More typically, tasks are executed in some thread other
49 * limitation on how and when tasks are scheduled. The executor below
50 * serializes the submission of tasks to a second executor,
55 * final Queue<Runnable> tasks = new ArrayDeque<Runnable>();
64 * tasks.offer(new Runnable() {
79 * if ((active = tasks.poll()) != null) {
|
| CompletionService.java | 10 * A service that decouples the production of new asynchronous tasks
11 * from the consumption of the results of completed tasks. Producers
12 * <tt>submit</tt> tasks for execution. Consumers <tt>take</tt>
13 * completed tasks and process their results in the order they
15 * manage asynchronous IO, in which tasks that perform reads are
21 * {@link Executor} to actually execute the tasks, in which case the
|
| ThreadPoolExecutor.java | 23 * asynchronous tasks, due to reduced per-task invocation overhead,
25 * including threads, consumed when executing a collection of tasks.
27 * statistics, such as the number of completed tasks.
60 * tasks. Most typically, core and maximum pool sizes are set only
67 * started only when new tasks arrive, but this can be overridden
82 * continue, but might not be able to execute any tasks.</dd>
104 * submitted tasks. The use of this queue interacts with pool sizing:
126 * queue is a {@link SynchronousQueue} that hands off tasks to threads
132 * avoid rejection of new submitted tasks. This in turn admits the
138 * capacity) will cause new tasks to wait in the queue when al
1349 List<Runnable> tasks; local
[all...] |
| /frameworks/base/docs/html/training/ |
| building-graphics.jd | 8 <p>These classes teach you how to accomplish tasks with graphics
|
| /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/chromium/base/threading/ |
| worker_pool.h | 16 // This is a facility that runs tasks that don't require a specific thread or
20 // for the worker pool threads to finish on shutdown, so the tasks running
27 // should be used for tasks that will take a long time to execute. Returns
|
| /bionic/libc/bionic/ |
| cpuacct.c | 43 count = snprintf(buf, sizeof(buf), "/acct/uid/%d/tasks", uid);
46 /* Note: sizeof("tasks") returns 6, which includes the NULL char */
47 buf[count - sizeof("tasks")] = 0;
51 /* Note: sizeof("tasks") returns 6, which includes the NULL char */
52 buf[count - sizeof("tasks")] = '/';
|
| /external/jmdns/src/javax/jmdns/impl/tasks/resolver/ |
| ServiceResolver.java | 5 package javax.jmdns.impl.tasks.resolver;
34 * @see javax.jmdns.impl.tasks.DNSTask#getName()
43 * @see javax.jmdns.impl.tasks.Resolver#addAnswers(javax.jmdns.impl.DNSOutgoing)
59 * @see javax.jmdns.impl.tasks.Resolver#addQuestions(javax.jmdns.impl.DNSOutgoing)
71 * @see javax.jmdns.impl.tasks.Resolver#description()
|
| TypeResolver.java | 5 package javax.jmdns.impl.tasks.resolver;
36 * @see javax.jmdns.impl.tasks.DNSTask#getName()
45 * @see javax.jmdns.impl.tasks.Resolver#addAnswers(javax.jmdns.impl.DNSOutgoing)
60 * @see javax.jmdns.impl.tasks.Resolver#addQuestions(javax.jmdns.impl.DNSOutgoing)
69 * @see javax.jmdns.impl.tasks.Resolver#description()
|
| /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/jmdns/src/javax/jmdns/impl/tasks/state/ |
| Prober.java | 5 package javax.jmdns.impl.tasks.state;
39 * @see javax.jmdns.impl.tasks.DNSTask#getName()
57 * @see javax.jmdns.impl.tasks.DNSTask#start(java.util.Timer)
85 * @see javax.jmdns.impl.tasks.state.DNSStateTask#getTaskDescription()
94 * @see javax.jmdns.impl.tasks.state.DNSStateTask#checkRunCondition()
103 * @see javax.jmdns.impl.tasks.state.DNSStateTask#createOugoing()
112 * @see javax.jmdns.impl.tasks.state.DNSStateTask#buildOutgoingForDNS(javax.jmdns.impl.DNSOutgoing)
126 * @see javax.jmdns.impl.tasks.state.DNSStateTask#buildOutgoingForInfo(javax.jmdns.impl.ServiceInfoImpl, javax.jmdns.impl.DNSOutgoing)
140 * @see javax.jmdns.impl.tasks.state.DNSStateTask#recoverTask(java.lang.Throwable)
149 * @see javax.jmdns.impl.tasks.state.DNSStateTask#advanceTask(
[all...] |
| /packages/apps/Email/tests/src/com/android/emailcommon/utility/ |
| DelayedOperationsTests.java | 56 // Execute all pending tasks!
62 // No pending tasks.
91 // Execute all pending tasks!
97 // No pending tasks.
126 // There should be no pending tasks in handler.
132 // No pending tasks.
|
| /external/jmdns/src/javax/jmdns/impl/tasks/ |
| RecordReaper.java | 5 package javax.jmdns.impl.tasks;
29 * @see javax.jmdns.impl.tasks.DNSTask#getName()
38 * @see javax.jmdns.impl.tasks.DNSTask#start(java.util.Timer)
|
| /development/ndk/platforms/android-3/include/linux/sunrpc/ |
| sched.h | 145 struct list_head tasks[RPC_NR_PRIORITY]; member in struct:rpc_wait_queue
160 #define RPC_WAITQ_INIT(var,qname) { .lock = SPIN_LOCK_UNLOCKED, .tasks = { [0] = LIST_HEAD_INIT(var.tasks[0]), [1] = LIST_HEAD_INIT(var.tasks[1]), [2] = LIST_HEAD_INIT(var.tasks[2]), }, }
162 #define RPC_WAITQ_INIT(var,qname) { .lock = SPIN_LOCK_UNLOCKED, .tasks = { [0] = LIST_HEAD_INIT(var.tasks[0]), [1] = LIST_HEAD_INIT(var.tasks[1]), [2] = LIST_HEAD_INIT(var.tasks[2]), }, .name = qname, }
|
| /development/samples/ContactManager/ |
| _index.html | 6 <p>In most cases, you will want to ask the existing Contacts activity to handle these tasks for you,
|
| /external/chromium/chrome/browser/ui/webui/chromeos/ |
| mobile_setup_ui.h | 12 // that is used in Chrome OS activate modem and perform plan subscription tasks.
|
| sim_unlock_ui.h | 14 // in Chrome OS for specific tasks:
|
| /external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/plugins/org.eclipse.build.tools/properties/ |
| _README.txt | 8 Or, you can call the Tasks themselves within another Java class.
|
| /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);
|
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
| BatchingNamedTaskExecutor.java | 26 * Executes NamedTasks in batches of a given size. Tasks are queued until
36 /** Queue of tasks waiting to be dispatched to mExecutor **/
42 * @param executor A SourceTaskExecutor for actually executing the tasks.
80 * Cancel any unstarted tasks running in this executor. This instance
|
| /prebuilts/ndk/4/platforms/android-3/arch-arm/usr/include/linux/sunrpc/ |
| sched.h | 145 struct list_head tasks[RPC_NR_PRIORITY]; member in struct:rpc_wait_queue
160 #define RPC_WAITQ_INIT(var,qname) { .lock = SPIN_LOCK_UNLOCKED, .tasks = { [0] = LIST_HEAD_INIT(var.tasks[0]), [1] = LIST_HEAD_INIT(var.tasks[1]), [2] = LIST_HEAD_INIT(var.tasks[2]), }, }
162 #define RPC_WAITQ_INIT(var,qname) { .lock = SPIN_LOCK_UNLOCKED, .tasks = { [0] = LIST_HEAD_INIT(var.tasks[0]), [1] = LIST_HEAD_INIT(var.tasks[1]), [2] = LIST_HEAD_INIT(var.tasks[2]), }, .name = qname, }
|
| /prebuilts/ndk/4/platforms/android-4/arch-arm/usr/include/linux/sunrpc/ |
| sched.h | 145 struct list_head tasks[RPC_NR_PRIORITY]; member in struct:rpc_wait_queue
160 #define RPC_WAITQ_INIT(var,qname) { .lock = SPIN_LOCK_UNLOCKED, .tasks = { [0] = LIST_HEAD_INIT(var.tasks[0]), [1] = LIST_HEAD_INIT(var.tasks[1]), [2] = LIST_HEAD_INIT(var.tasks[2]), }, }
162 #define RPC_WAITQ_INIT(var,qname) { .lock = SPIN_LOCK_UNLOCKED, .tasks = { [0] = LIST_HEAD_INIT(var.tasks[0]), [1] = LIST_HEAD_INIT(var.tasks[1]), [2] = LIST_HEAD_INIT(var.tasks[2]), }, .name = qname, }
|
| /prebuilts/ndk/4/platforms/android-5/arch-arm/usr/include/linux/sunrpc/ |
| sched.h | 145 struct list_head tasks[RPC_NR_PRIORITY]; member in struct:rpc_wait_queue
160 #define RPC_WAITQ_INIT(var,qname) { .lock = SPIN_LOCK_UNLOCKED, .tasks = { [0] = LIST_HEAD_INIT(var.tasks[0]), [1] = LIST_HEAD_INIT(var.tasks[1]), [2] = LIST_HEAD_INIT(var.tasks[2]), }, }
162 #define RPC_WAITQ_INIT(var,qname) { .lock = SPIN_LOCK_UNLOCKED, .tasks = { [0] = LIST_HEAD_INIT(var.tasks[0]), [1] = LIST_HEAD_INIT(var.tasks[1]), [2] = LIST_HEAD_INIT(var.tasks[2]), }, .name = qname, }
|
| /prebuilts/ndk/4/platforms/android-5/arch-x86/usr/include/linux/sunrpc/ |
| sched.h | 145 struct list_head tasks[RPC_NR_PRIORITY]; member in struct:rpc_wait_queue
160 #define RPC_WAITQ_INIT(var,qname) { .lock = SPIN_LOCK_UNLOCKED, .tasks = { [0] = LIST_HEAD_INIT(var.tasks[0]), [1] = LIST_HEAD_INIT(var.tasks[1]), [2] = LIST_HEAD_INIT(var.tasks[2]), }, }
162 #define RPC_WAITQ_INIT(var,qname) { .lock = SPIN_LOCK_UNLOCKED, .tasks = { [0] = LIST_HEAD_INIT(var.tasks[0]), [1] = LIST_HEAD_INIT(var.tasks[1]), [2] = LIST_HEAD_INIT(var.tasks[2]), }, .name = qname, }
|
| /prebuilts/ndk/4/platforms/android-8/arch-arm/usr/include/linux/sunrpc/ |
| sched.h | 145 struct list_head tasks[RPC_NR_PRIORITY]; member in struct:rpc_wait_queue
160 #define RPC_WAITQ_INIT(var,qname) { .lock = SPIN_LOCK_UNLOCKED, .tasks = { [0] = LIST_HEAD_INIT(var.tasks[0]), [1] = LIST_HEAD_INIT(var.tasks[1]), [2] = LIST_HEAD_INIT(var.tasks[2]), }, }
162 #define RPC_WAITQ_INIT(var,qname) { .lock = SPIN_LOCK_UNLOCKED, .tasks = { [0] = LIST_HEAD_INIT(var.tasks[0]), [1] = LIST_HEAD_INIT(var.tasks[1]), [2] = LIST_HEAD_INIT(var.tasks[2]), }, .name = qname, }
|
