Home
last modified time | relevance | path

Searched refs:tasks (Results 1 – 25 of 135) sorted by relevance

123456

/external/guava/guava-bootstrap/src/java/util/concurrent/
DAbstractExecutorService.java38 private <T> T doInvokeAny(Collection<? extends Callable<T>> tasks, in doInvokeAny() argument
41 if (tasks == null) in doInvokeAny()
43 int ntasks = tasks.size(); in doInvokeAny()
53 Iterator<? extends Callable<T>> it = tasks.iterator(); in doInvokeAny()
104 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny() argument
107 return doInvokeAny(tasks, false, 0); in invokeAny()
114 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, in invokeAny() argument
117 return doInvokeAny(tasks, true, unit.toNanos(timeout)); in invokeAny()
120 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() argument
122 if (tasks == null) in invokeAll()
[all …]
DExecutorService.java34 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() argument
38 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll() argument
41 <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny() argument
45 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny() argument
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DWrappingExecutorServiceTest.java99 List<Callable<String>> tasks = createTasks(3); in testInvokeAll() local
103 List<Future<String>> futures = testExecutor.invokeAll(tasks); in testInvokeAll()
112 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); in testInvokeAll()
119 List<Callable<String>> tasks = createTasks(3); in testInvokeAny() local
123 String s = testExecutor.invokeAny(tasks); in testInvokeAny()
132 String s = testExecutor.invokeAny(tasks, timeout, unit); in testInvokeAny()
216 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() argument
219 assertTaskWrapped(tasks); in invokeAll()
220 return inline.invokeAll(tasks); in invokeAll()
225 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll() argument
[all …]
DSerializingExecutorTest.java42 Queue<Runnable> tasks = Lists.newLinkedList(); field in SerializingExecutorTest.FakeExecutor
44 tasks.add(command); in execute()
48 return !tasks.isEmpty(); in hasNext()
53 tasks.remove().run(); in runNext()
DWrappingScheduledExecutorServiceTest.java169 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() argument
176 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll() argument
182 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny() argument
188 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny() argument
/external/guava/guava/src/com/google/common/util/concurrent/
DAbstractListeningExecutorService.java69 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) throws InterruptedException, in invokeAny() argument
72 return invokeAnyImpl(this, tasks, false, 0); in invokeAny()
79 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny() argument
81 return invokeAnyImpl(this, tasks, true, unit.toNanos(timeout)); in invokeAny()
85 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() argument
87 if (tasks == null) { in invokeAll()
90 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); in invokeAll()
93 for (Callable<T> t : tasks) { in invokeAll()
117 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, in invokeAll() argument
119 if (tasks == null || unit == null) { in invokeAll()
[all …]
DWrappingExecutorService.java84 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)
129 return delegate.invokeAny(wrapTasks(tasks));
134 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
136 return delegate.invokeAny(wrapTasks(tasks), timeout, unit);
DForwardingExecutorService.java55 Collection<? extends Callable<T>> tasks) throws InterruptedException { in invokeAll() argument
56 return delegate().invokeAll(tasks); in invokeAll()
61 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll() argument
63 return delegate().invokeAll(tasks, timeout, unit); in invokeAll()
67 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny() argument
69 return delegate().invokeAny(tasks); in invokeAny()
74 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny() argument
76 return delegate().invokeAny(tasks, timeout, unit); in invokeAny()
DListeningExecutorService.java74 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() argument
96 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll() argument
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/
DSameThreadScheduledExecutorService.java101 Collection<? extends Callable<T>> tasks) throws InterruptedException { in invokeAll() argument
102 Preconditions.checkNotNull(tasks, "tasks must not be null!"); in invokeAll()
103 return delegate.invokeAll(tasks); in invokeAll()
108 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll() argument
110 Preconditions.checkNotNull(tasks, "tasks must not be null!"); in invokeAll()
112 return delegate.invokeAll(tasks, timeout, unit); in invokeAll()
116 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny() argument
118 Preconditions.checkNotNull(tasks, "tasks must not be null!"); in invokeAny()
119 return delegate.invokeAny(tasks); in invokeAny()
123 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, in invokeAny() argument
[all …]
/external/guava/guava-tests/test/com/google/common/eventbus/
DAsyncEventBusTest.java56 List<Runnable> tasks = executor.getTasks(); in testBasicDistribution() local
57 assertEquals("One event dispatch task should be queued.", 1, tasks.size()); in testBasicDistribution()
59 tasks.get(0).run(); in testBasicDistribution()
73 List<Runnable> tasks = Lists.newArrayList(); field in AsyncEventBusTest.FakeExecutor
77 tasks.add(task); in execute()
81 return tasks; in getTasks()
/external/vogar/src/vogar/tasks/
DTaskQueue.java17 package vogar.tasks;
39 private final LinkedList<Task> tasks = new LinkedList<Task>(); field in TaskQueue
53 tasks.add(task); in enqueue()
56 public void enqueueAll(Collection<Task> tasks) { in enqueueAll() argument
57 this.tasks.addAll(tasks); in enqueueAll()
61 return new ArrayList<Task>(tasks); in getTasks()
91 for (Task task : tasks) { in printTasks()
116 for (Task task : tasks) { in printProblemTasks()
196 for (Iterator<Task> it = tasks.iterator(); it.hasNext(); ) { in promoteBlockedTasks()
/external/robolectric/src/main/java/com/xtremelabs/robolectric/shadows/
DShadowActivityManager.java17 private List<ActivityManager.RunningTaskInfo> tasks = field in ShadowActivityManager
28 return tasks; in getRunningTasks()
52 public void setTasks(List<ActivityManager.RunningTaskInfo> tasks) { in setTasks() argument
53 this.tasks = tasks; in setTasks()
/external/jmdns/src/javax/jmdns/impl/
DDNSTaskStarter.java13 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;
/external/linux-tools-perf/src/tools/perf/scripts/python/
Dsched-migration.py98 def __init__(self, tasks = [0], event = RunqueueEventUnknown()): argument
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:
135 next_tasks = self.tasks[:] + tuple([new])
[all …]
/external/ltrace/sysdeps/linux-gnu/
Dtrace.c191 if (pids->tasks[i].pid == pid) in get_task_info()
192 return &pids->tasks[i]; in get_task_info()
202 struct pid_task *n = realloc(pids->tasks, in add_task_info()
203 sizeof(*pids->tasks) * ns); in add_task_info()
206 pids->tasks = n; in add_task_info()
209 struct pid_task * task_info = &pids->tasks[pids->count++]; in add_task_info()
354 if (self->pids.tasks[i].pid != 0 in process_stopping_done()
355 && (self->pids.tasks[i].delivered in process_stopping_done()
356 || self->pids.tasks[i].sysret)) in process_stopping_done()
357 continue_process(self->pids.tasks[i].pid); in process_stopping_done()
[all …]
Dproc.c240 pid_t *tasks = NULL; in process_tasks() local
249 free(tasks); in process_tasks()
259 pid_t *ntasks = realloc(tasks, in process_tasks()
260 sizeof(*tasks) * alloc); in process_tasks()
263 tasks = ntasks; in process_tasks()
266 tasks[n++] = npid; in process_tasks()
272 *ret_tasks = tasks; in process_tasks()
/external/vogar/src/vogar/android/
DDeviceRuntime.java33 import vogar.tasks.RunActionTask;
34 import vogar.tasks.Task;
72 private void dexAndPush(Set<Task> tasks, String name, File jar, Action action) { in dexAndPush() argument
77 tasks.add(dex); in dexAndPush()
78 tasks.add(run.target.pushTask(localDex, deviceDex).afterSuccess(dex)); in dexAndPush()
DActivityMode.java28 import vogar.tasks.ExtractJarResourceTask;
29 import vogar.tasks.Task;
/external/mesa3d/src/gallium/drivers/llvmpipe/
Dlp_rast.c754 rasterize_scene( &rast->tasks[0], scene ); in lp_rast_queue_scene()
768 pipe_semaphore_signal(&rast->tasks[i].work_ready); in lp_rast_queue_scene()
787 pipe_semaphore_wait(&rast->tasks[i].work_done); in lp_rast_finish()
866 pipe_semaphore_init(&rast->tasks[i].work_ready, 0); in create_rast_threads()
867 pipe_semaphore_init(&rast->tasks[i].work_done, 0); in create_rast_threads()
869 (void *) &rast->tasks[i]); in create_rast_threads()
896 for (i = 0; i < Elements(rast->tasks); i++) { in lp_rast_create()
897 struct lp_rasterizer_task *task = &rast->tasks[i]; in lp_rast_create()
936 pipe_semaphore_signal(&rast->tasks[i].work_ready); in lp_rast_destroy()
946 pipe_semaphore_destroy(&rast->tasks[i].work_ready); in lp_rast_destroy()
[all …]
/external/vogar/src/vogar/
DDriver.java27 import vogar.tasks.BuildActionTask;
28 import vogar.tasks.PrepareTarget;
29 import vogar.tasks.PrepareUserDirTask;
30 import vogar.tasks.RetrieveFilesTask;
31 import vogar.tasks.RmTask;
32 import vogar.tasks.Task;
/external/llvm/test/YAMLParser/
Dconstruct-pairs.data4 Block tasks: !!pairs
9 Flow tasks: !!pairs [ meeting: with team, meeting: with boss ]
/external/jetty/lib/
Djetty-util-6.1.26.pom37 <tasks>
40 </tasks>
50 <tasks>
53 </tasks>
/external/guava/guava-tests/test/com/google/common/cache/
DCacheLoaderTest.java40 private LinkedList<Runnable> tasks = Lists.newLinkedList(); field in CacheLoaderTest.QueuingExecutor
44 tasks.add(task); in execute()
48 tasks.removeFirst().run(); in runNext()
/external/libmtp/examples/
Devolution-sync.sh65 cat $HOME/.evolution/tasks/local/system/tasks.ics \

123456