| /external/guice/extensions/service/src/com/google/inject/service/ |
| CompositeService.java | 81 final List<Future<State>> tasks = Lists.newArrayList();
83 tasks.add(injector.getInstance(service).start());
86 return futureGet(tasks, State.STARTED);
90 final List<Future<State>> tasks = Lists.newArrayList(); local
92 tasks.add(injector.getInstance(service).stop());
95 return futureGet(tasks, State.STOPPED);
104 private FutureTask<Service.State> futureGet(final List<Future<Service.State>> tasks,
109 for (Future<Service.State> task : tasks) {
|
| /libcore/dalvik/src/main/java/dalvik/system/ |
| ZygoteHooks.java | 84 File tasks = new File("/proc/self/task"); local
87 while (tasks.list().length > 1) {
|
| /sdk/ |
| release.md | 6 gradle --init-script release.gradle <tasks
|
| /prebuilts/tools/common/m2/repository/org/jetbrains/kotlin/kotlin-gradle-plugin-core/0.12.613/ |
| kotlin-gradle-plugin-core-0.12.613.jar | |
| /frameworks/base/services/core/java/com/android/server/am/ |
| LaunchingTaskPositioner.java | 36 * and compares corners of the task with corners of existing tasks. If some two pairs of corners are
107 * we mean that two tasks have left-top corner very close to each other, so one might get
111 * @param tasks Existing tasks with which we don't want to collide.
115 void updateDefaultBounds(TaskRecord task, ArrayList<TaskRecord> tasks,
121 positionCenter(task, tasks, mDefaultFreeformWidth, mDefaultFreeformHeight);
130 positionTopRight(task, tasks, width, height);
132 positionTopLeft(task, tasks, width, height);
136 positionBottomRight(task, tasks, width, height);
138 positionBottomLeft(task, tasks, width, height)
[all...] |
| /build/core/tasks/ |
| build_custom_images.mk | 62 $(eval include $(BUILD_SYSTEM)/tasks/tools/build_custom_image.mk))
|
| /external/guava/guava-bootstrap/src/java/util/concurrent/ |
| AbstractExecutorService.java | 38 private <T> T doInvokeAny(Collection<? extends Callable<T>> tasks,
41 if (tasks == null)
43 int ntasks = tasks.size();
53 Iterator<? extends Callable<T>> it = tasks.iterator();
104 public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
107 return doInvokeAny(tasks, false, 0);
114 public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
117 return doInvokeAny(tasks, true, unit.toNanos(timeout));
120 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
122 if (tasks == null
[all...] |
| 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)
|
| /external/vogar/src/vogar/android/ |
| UninstallApkTask.java | 20 import vogar.tasks.Task;
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| AbstractExecutorService.java | 118 private <T> T doInvokeAny(Collection<? extends Callable<T>> tasks,
121 if (tasks == null)
123 int ntasks = tasks.size();
131 // parallelism, check to see if previously submitted tasks are
141 Iterator<? extends Callable<T>> it = tasks.iterator();
188 public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
191 return doInvokeAny(tasks, false, 0);
198 public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
201 return doInvokeAny(tasks, true, unit.toNanos(timeout));
204 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
[all...] |
| ExecutorService.java | 19 * one or more asynchronous tasks.
22 * it to reject new tasks. Two different methods are provided for
24 * method will allow previously submitted tasks to execute before
26 * tasks from starting and attempts to stop currently executing tasks.
27 * Upon termination, an executor has no tasks actively executing, no
28 * tasks awaiting execution, and no new tasks can be submitted. An
37 * tasks and then waiting for at least one, or all, to
81 * first by calling {@code shutdown} to reject incoming tasks, and the
[all...] |
| /packages/apps/Camera2/src/com/android/camera/processing/imagebackend/ |
| ImageTaskManager.java | 30 * Spawns dependent tasks from internal implementation of set of tasks. If a
37 * @param tasks The set of tasks to be run
38 * @return whether tasks are successfully submitted.
40 public boolean appendTasks(ImageToProcess img, Set<TaskImageContainer> tasks);
46 * @return whether tasks are successfully submitted.
54 * and/or unblocking the caller. Should ONLY be called by the tasks running
|
| /external/autotest/scheduler/ |
| monitor_db_cleanup_test.py | 43 tasks = models.SpecialTask.objects.all()
44 self.assertEquals(len(tasks), 1)
45 self.assertEquals(tasks[0].host.id, 1)
46 self.assertEquals(tasks[0].task, models.SpecialTask.Task.VERIFY)
69 tasks = models.SpecialTask.objects.all()
71 self.assertEquals(len(tasks), 2)
72 self.assertTrue(tasks[0].host.id in (1, 4, 5, 6))
73 self.assertTrue(tasks[1].host.id in (1, 4, 5, 6))
74 self.assertEquals(tasks[0].task, models.SpecialTask.Task.VERIFY)
75 self.assertEquals(tasks[1].task, models.SpecialTask.Task.VERIFY
[all...] |
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| WrappingExecutorService.java | 36 * {@linkplain #wrapTask(Callable) wrap} tasks before they are submitted
79 * Wraps a collection of tasks.
81 * @throws NullPointerException if any element of {@code tasks} is null
84 Collection<? extends Callable<T>> tasks) {
86 for (Callable<T> task : tasks) {
115 Collection<? extends Callable<T>> tasks) throws InterruptedException {
116 return delegate.invokeAll(wrapTasks(tasks));
121 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
123 return delegate.invokeAll(wrapTasks(tasks), timeout, unit);
127 public final <T> T invokeAny(Collection<? extends Callable<T>> tasks)
[all...] |
| ListeningExecutorService.java | 64 * {@code List<ListenableFuture<T>> futures = (List) executor.invokeAll(tasks);}
67 * @return A list of {@code ListenableFuture} instances representing the tasks, in the same
74 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
84 * {@code List<ListenableFuture<T>> futures = (List) executor.invokeAll(tasks, timeout, unit);}
87 * @return a list of {@code ListenableFuture} instances representing the tasks, in the same
90 * tasks will not have completed.
96 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
|
| /external/vogar/src/vogar/tasks/ |
| TaskQueue.java | 17 package vogar.tasks;
31 * A set of tasks to execute.
39 private final LinkedList<Task> tasks = new LinkedList<Task>(); field in class:TaskQueue
53 tasks.add(task);
56 public void enqueueAll(Collection<Task> tasks) {
57 this.tasks.addAll(tasks);
61 return new ArrayList<Task>(tasks);
91 for (Task task : tasks) {
120 for (Task task : tasks) {
[all...] |
| /frameworks/data-binding/compilerCommon/ |
| build.gradle | 47 project.tasks.create(name : "generateXmlParser", type : JavaExec) {
54 project.tasks.create(name : "generateGrammar", type : JavaExec) {
60 tasks.create(name : 'exportBuildVersions') << {
78 tasks['jar'].dependsOn('exportBuildVersions')
79 tasks['exportBuildVersions'].dependsOn('processResources')
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| WrappingExecutorServiceTest.java | 96 List<Callable<String>> tasks = createTasks(3); local
100 List<Future<String>> futures = testExecutor.invokeAll(tasks);
109 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit);
116 List<Callable<String>> tasks = createTasks(3); local
120 String s = testExecutor.invokeAny(tasks);
129 String s = testExecutor.invokeAny(tasks, timeout, unit);
213 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
216 assertTaskWrapped(tasks);
217 return inline.invokeAll(tasks);
222 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit
[all...] |
| /external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/configuration/org.eclipse.osgi/bundles/121/1/.cp/lib/ |
| apitooling-ant.jar | |
| /tools/test/connectivity/acts/tests/google/tel/live/ |
| TelLiveVoiceTest.py | 225 tasks = [(phone_setup_voice_general, (self.log, ads[0])),
227 if not multithread_func(self.log, tasks):
248 tasks = [(phone_setup_voice_general, (self.log, ads[0])),
250 if not multithread_func(self.log, tasks):
271 tasks = [(phone_setup_volte, (self.log, ads[0])), (phone_setup_volte,
273 if not multithread_func(self.log, tasks):
295 tasks = [(phone_setup_volte, (self.log, ads[0])), (phone_setup_volte,
297 if not multithread_func(self.log, tasks):
328 tasks = [(phone_setup_volte, (self.log, ads[0])), (phone_setup_volte,
330 if not multithread_func(self.log, tasks)
[all...] |
| TelLiveSmsTest.py | 189 tasks = [(phone_setup_voice_general, (self.log, ads[0])),
191 if not multithread_func(self.log, tasks):
211 tasks = [(phone_setup_voice_general, (self.log, ads[0])),
213 if not multithread_func(self.log, tasks):
233 tasks = [(phone_setup_voice_2g, (self.log, ads[0])),
235 if not multithread_func(self.log, tasks):
255 tasks = [(phone_setup_voice_2g, (self.log, ads[0])),
257 if not multithread_func(self.log, tasks):
278 tasks = [(phone_setup_3g, (self.log, ads[0])),
280 if not multithread_func(self.log, tasks)
[all...] |
| /external/libgdx/backends/gdx-backends-gwt/src/com/badlogic/gdx/backends/gwt/emu/com/badlogic/gdx/utils/ |
| Timer.java | 23 /** Executes tasks in the future on the main loop thread.
41 private final Array<Task> tasks = new Array(false, 8);
field in class:Timer
68 synchronized (tasks) {
69 tasks.add(task);
75 /** Stops the timer, tasks will not be executed and time that passes will not be applied to the task delays. */
92 /** Cancels all tasks. */
94 synchronized (tasks) {
95 for (int i = 0, n = tasks.size; i < n; i++)
96 tasks.get(i).cancel();
97 tasks.clear();
[all...] |
| /external/autotest/site_utils/suite_scheduler/ |
| base_event.py | 54 Tasks get de-duped before we even try to schedule them.
102 def tasks(self): member in class:BaseEvent
106 @tasks.setter
107 def tasks(self, iterable_of_tasks): member in class:BaseEvent
108 """Set the tasks property with an iterable.
125 self.tasks = to_merge.tasks
166 """Filter the tasks to only return tasks should run now.
169 this function in Nightly class will only return the tasks set to run i
[all...] |
| /system/connectivity/shill/cellular/ |
| cellular_capability_classic.cc | 145 void CellularCapabilityClassic::RunNextStep(CellularTaskList* tasks) {
146 CHECK(!tasks->empty());
147 SLOG(this, 2) << __func__ << ": " << tasks->size() << " remaining tasks";
148 Closure task = (*tasks)[0];
149 tasks->erase(tasks->begin());
156 CellularTaskList* tasks,
158 if ((ignore_error || error.IsSuccess()) && !tasks->empty()) {
159 RunNextStep(tasks);
220 CellularTaskList* tasks = new CellularTaskList(); local
[all...] |
| /frameworks/base/core/tests/overlaytests/ |
| testrunner.py | 389 def __init__(self, type, tasks):
391 self.tasks = tasks
400 for t in self.tasks:
407 tasks = [
417 return CompoundTask(TASK_DISABLE_OVERLAYS, tasks)
420 tasks = [
427 return CompoundTask(TASK_ENABLE_SINGLE_OVERLAY, tasks)
430 tasks = [
439 return CompoundTask(TASK_ENABLE_MULTIPLE_OVERLAYS, tasks)
569 tasks = [] variable
[all...] |
