| /prebuilts/ndk/8/platforms/android-9/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, }
|
| /external/chromium/base/ |
| message_pump_glib_unittest.cc | 21 // events can run tasks. This is intended to mock gtk events (the corresponding
200 // Checks that tasks posted by events are executed before the next event if
230 // Tests that we process tasks while waiting for new events.
235 // After all the previous tasks have executed, enqueue an event that will
244 // Tests that we process delayed tasks while waiting for new events.
251 // After all the previous tasks have executed, enqueue an event that will
253 // This relies on the fact that delayed tasks are executed in delay order.
286 // This class is a helper for the concurrent events / posted tasks test below.
287 // It will quit the main loop once enough tasks and events have been processed,
340 // Tests that posted tasks don't starve events, nor the opposite
[all...] |
| task_queue_unittest.cc | 129 // Run the task which pushes two more tasks.
132 // None of the pushed tasks shoudl have run yet.
139 // Now run the nested tasks.
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| ForkJoinTask.java | 28 * Abstract base class for tasks that run within a {@link ForkJoinPool}.
30 * lighter weight than a normal thread. Huge numbers of tasks and
47 * reflecting their intended use as computational tasks calculating
53 * other blocking synchronization apart from joining other tasks or
55 * cooperate with fork/join scheduling. Tasks should also not perform
58 * tasks. Minor breaches of these restrictions, for example using
83 * may be useful when a set of tasks are being executed, and you need
87 * of tasks and joining them all.
89 * <p>The execution status of tasks may be queried at several levels
121 * tasks cyclically wait for each other. However, this framewor
[all...] |
| ScheduledThreadPoolExecutor.java | 27 * <p>Delayed tasks execute no sooner than they are enabled, but
29 * enabled, they will commence. Tasks scheduled for exactly the same
37 * may also cause unbounded retention of cancelled tasks.
54 * without threads to handle tasks once they become eligible to run.
102 * tasks, even those that don't require scheduling (i.e.,
105 * delayed tasks with a delay of zero.
115 * tasks that should NOT be run after shutdown, as well as
126 * False if should cancel/suppress periodic tasks on shutdown.
131 * False if should cancel non-periodic tasks on shutdown.
163 * Period in nanoseconds for repeating tasks. A positiv
[all...] |
| /packages/apps/QuickSearchBox/src/com/android/quicksearchbox/util/ |
| NamedTaskExecutor.java | 20 * Runs tasks that have a name tag.
32 * Stops any unstarted tasks from running. Implementations of this method must be
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| 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)
|
| /external/jmdns/src/javax/jmdns/impl/tasks/resolver/ |
| ServiceInfoResolver.java | 5 package javax.jmdns.impl.tasks.resolver;
35 * @see javax.jmdns.impl.tasks.DNSTask#getName()
58 * @see javax.jmdns.impl.tasks.Resolver#addAnswers(javax.jmdns.impl.DNSOutgoing)
77 * @see javax.jmdns.impl.tasks.Resolver#addQuestions(javax.jmdns.impl.DNSOutgoing)
95 * @see javax.jmdns.impl.tasks.Resolver#description()
|
| DNSResolverTask.java | 2 package javax.jmdns.impl.tasks.resolver;
12 import javax.jmdns.impl.tasks.DNSTask;
15 * This is the root class for all resolver tasks.
45 * @see javax.jmdns.impl.tasks.DNSTask#start(java.util.Timer)
|
| /external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/plugins/org.eclipse.pde.build_3.6.1.R36x_v20100823/lib/ |
| pdebuild-ant.jar | |
| /external/chromium/chrome/browser/service/ |
| service_process_control.cc | 58 // The tasks executed here may add more tasks to the vector. So copy
61 TaskList tasks; local
62 tasks.swap(connect_done_tasks_);
63 RunAllTasksHelper(&tasks);
64 DCHECK(tasks.empty());
67 tasks.swap(connect_success_tasks_);
68 RunAllTasksHelper(&tasks);
69 DCHECK(tasks.empty());
73 tasks.swap(connect_failure_tasks_)
[all...] |
| /external/chromium/base/threading/ |
| worker_pool_posix_unittest.cc | 28 const std::queue<Task*>& tasks() const { return pool_->tasks_; } function in class:base::PosixDynamicThreadPool::PosixDynamicThreadPoolPeer
183 EXPECT_EQ(0U, peer_.tasks().size());
202 // Add another 2 tasks. One should reuse the existing worker thread.
216 // Add two blocking tasks.
220 EXPECT_EQ(0, counter_) << "Blocking tasks should not have started yet.";
232 // Add two non blocking tasks and wait for them to finish.
237 // Add two blocking tasks, start them simultaneously, and wait for them to
|
| worker_pool_posix.h | 6 // adds threads as necessary to handle all tasks. It keeps old threads around
10 // potentially long running tasks (such as DNS lookup) do not block process
53 // Indicates that the thread pool is going away. Stops handing out tasks to
73 // Signal()s worker threads to let them know more tasks are available.
|
| /bionic/libc/kernel/common/linux/sunrpc/ |
| sched.h | 155 struct list_head tasks[RPC_NR_PRIORITY]; member in struct:rpc_wait_queue
171 #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]), }, }
174 #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, }
|
| /frameworks/base/libs/hwui/thread/ |
| TaskManager.h | 44 * Returns true if this task manager can run tasks,
51 * Stops all allocated threads. Adding tasks will start
89 // Lock for the list of tasks
|
| /packages/apps/Dialer/src/com/android/dialer/util/ |
| AsyncTaskExecutor.java | 31 * tasks have been submitted and control their execution in an orderly manner.
33 * Another benefit in due course will be the management of the submitted tasks. An extension to this
34 * interface is planned to allow Activities to easily cancel all the submitted tasks that are still
|
| /cts/tests/tests/openglperf/src/android/openglperf/cts/ |
| GlAppSwitchTest.java | 122 List<ActivityManager.RunningTaskInfo> tasks = local
124 for (ActivityManager.RunningTaskInfo info : tasks) {
137 List<ActivityManager.RunningTaskInfo> tasks = local
139 for (ActivityManager.RunningTaskInfo info : tasks) {
|
| /development/scripts/app_engine_server/gae_shell/ |
| README | 6 Can be used for system administration tasks, as an interactive way to try out
|
| /external/antlr/antlr-3.4/runtime/ActionScript/project/ |
| build.xml | 13 <!-- Assume SDK 3.0 or greater has the ant tasks -->
14 <taskdef resource="flexTasks.tasks" classpath="${FLEX_HOME}/ant/lib/flexTasks.jar"/>
15 <taskdef resource="com/adobe/ac/ant/tasks/tasks.properties" classpath="${basedir}/lib/FlexAntTasks.jar"/>
|
| /external/libnfc-nci/halimpl/bcm2079x/include/ |
| buildcfg_hal.h | 27 #define GKI_MAX_TASKS 3 //total of 3 tasks
|
| /external/jmdns/src/javax/jmdns/impl/ |
| DNSTaskStarter.java | 13 import javax.jmdns.impl.tasks.RecordReaper;
14 import javax.jmdns.impl.tasks.Responder;
15 import javax.jmdns.impl.tasks.resolver.ServiceInfoResolver;
16 import javax.jmdns.impl.tasks.resolver.ServiceResolver;
17 import javax.jmdns.impl.tasks.resolver.TypeResolver;
18 import javax.jmdns.impl.tasks.state.Announcer;
19 import javax.jmdns.impl.tasks.state.Canceler;
20 import javax.jmdns.impl.tasks.state.Prober;
21 import javax.jmdns.impl.tasks.state.Renewer;
143 * The timer is used to dispatch all outgoing messages of JmDNS. It is also used to dispatch maintenance tasks for the DNS cache
[all...] |
| /external/chromium/chrome/browser/sync/notifier/ |
| cache_invalidation_packet_handler_unittest.cc | 63 // Take care of any tasks posted by the constructor.
75 // Take care of any tasks posted by HandleOutboundPacket().
|
| /external/chromium/chrome/browser/ui/cocoa/ |
| browser_test_helper.cc | 32 // Make sure any pending tasks run before we destroy other threads.
35 // Drop any new tasks for the IO and FILE threads.
|
| /external/chromium/base/synchronization/ |
| condition_variable_unittest.cc | 136 int shutdown_task_count_; // Number of tasks told to shutdown
137 int task_count_; // Number of assignment tasks waiting to be processed.
196 const int kTaskCount = 10; // Number of tasks in each mini-test here.
206 // If threads aren't in a wait state, they may start to gobble up tasks in
211 // Since we have no tasks yet, all threads should be waiting by now.
220 // Set up to make one worker do 30ms tasks sequentially.
230 // Wait till we at least start to handle tasks (and we're not all waiting).
234 // Wait until all 10 work tasks have at least been assigned.
238 // The last of the tasks *might* still be running, but... all but one should
239 // be done by now, since tasks are being done serially
[all...] |
| /external/linux-tools-perf/scripts/python/ |
| sched-migration.py | 98 def __init__(self, tasks = [0], event = RunqueueEventUnknown()):
99 self.tasks = tuple(tasks)
105 if taskState(prev_state) == "R" and next in self.tasks \
106 and prev in self.tasks:
112 next_tasks = list(self.tasks[:])
113 if prev in self.tasks:
125 if old not in self.tasks:
127 next_tasks = [task for task in self.tasks if task != old]
132 if new in self.tasks
[all...] |
