/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...] |