| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractListeningExecutorService.java | 63 private <T> T doInvokeAny(Collection<? extends Callable<T>> tasks, boolean timed, long nanos) in doInvokeAny() argument
65 int ntasks = tasks.size(); in doInvokeAny()
81 Iterator<? extends Callable<T>> it = tasks.iterator(); in doInvokeAny()
132 @Override public <T> T invokeAny(Collection<? extends Callable<T>> tasks) in invokeAny() argument
135 return doInvokeAny(tasks, false, 0); in invokeAny()
142 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAny() argument
144 return doInvokeAny(tasks, true, unit.toNanos(timeout)); in invokeAny()
147 @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() argument
149 if (tasks == null) { in invokeAll()
152 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); in invokeAll()
[all …]
|
| D | ForwardingExecutorService.java | 55 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()
|
| D | ListeningExecutorService.java | 69 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll() argument
86 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) in invokeAll() argument
|
| /external/guava/guava-tests/test/com/google/common/eventbus/ |
| D | AsyncEventBusTest.java | 54 List<Runnable> tasks = executor.getTasks(); in testBasicDistribution() local
55 assertEquals("One event dispatch task should be queued.", 1, tasks.size()); in testBasicDistribution()
57 tasks.get(0).run(); in testBasicDistribution()
71 List<Runnable> tasks = Lists.newArrayList(); field in AsyncEventBusTest.FakeExecutor
75 tasks.add(task); in execute()
79 return tasks; in getTasks()
|
| /external/robolectric/src/main/java/com/xtremelabs/robolectric/shadows/ |
| D | ShadowActivityManager.java | 17 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/ |
| D | 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;
|
| /external/kernel-headers/original/linux/sunrpc/ |
| D | sched.h | 206 struct list_head tasks[RPC_NR_PRIORITY]; /* task queue for each priority level */ member
228 .tasks = { \
229 [0] = LIST_HEAD_INIT(var.tasks[0]), \
230 [1] = LIST_HEAD_INIT(var.tasks[1]), \
231 [2] = LIST_HEAD_INIT(var.tasks[2]), \
237 .tasks = { \
238 [0] = LIST_HEAD_INIT(var.tasks[0]), \
239 [1] = LIST_HEAD_INIT(var.tasks[1]), \
240 [2] = LIST_HEAD_INIT(var.tasks[2]), \
|
| /external/guava/guava-bootstrap/src/java/util/concurrent/ |
| D | ExecutorService.java | 34 <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/chromium/chrome/browser/service/ |
| D | service_process_control.cc | 61 TaskList tasks; in RunConnectDoneTasks() local
62 tasks.swap(connect_done_tasks_); in RunConnectDoneTasks()
63 RunAllTasksHelper(&tasks); in RunConnectDoneTasks()
64 DCHECK(tasks.empty()); in RunConnectDoneTasks()
67 tasks.swap(connect_success_tasks_); in RunConnectDoneTasks()
68 RunAllTasksHelper(&tasks); in RunConnectDoneTasks()
69 DCHECK(tasks.empty()); in RunConnectDoneTasks()
73 tasks.swap(connect_failure_tasks_); in RunConnectDoneTasks()
74 RunAllTasksHelper(&tasks); in RunConnectDoneTasks()
75 DCHECK(tasks.empty()); in RunConnectDoneTasks()
|
| /external/linux-tools-perf/scripts/python/ |
| D | sched-migration.py | 98 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/llvm/test/YAMLParser/ |
| D | construct-pairs.data | 4 Block tasks: !!pairs
9 Flow tasks: !!pairs [ meeting: with team, meeting: with boss ]
|
| /external/libmtp/examples/ |
| D | evolution-sync.sh | 65 cat $HOME/.evolution/tasks/local/system/tasks.ics \
|
| /external/linux-tools-perf/Documentation/ |
| D | perf-bench.txt | 28 (executing 1000000 pipe operations between two tasks)
104 (executing 1000000 pipe operations between two tasks)
111 (executing 1000 pipe operations between two tasks)
|
| /external/jmdns/src/javax/jmdns/impl/tasks/resolver/ |
| D | DNSResolverTask.java | 2 package javax.jmdns.impl.tasks.resolver;
12 import javax.jmdns.impl.tasks.DNSTask;
|
| D | package-info.java | 1 package javax.jmdns.impl.tasks.resolver;
|
| D | TypeResolver.java | 5 package javax.jmdns.impl.tasks.resolver;
|
| /external/chromium/chrome/browser/resources/file_manager/js/ |
| D | mock_chrome.js | 68 var tasks =
82 var candidateTasks = [].concat(tasks);
|
| /external/jmdns/src/javax/jmdns/impl/tasks/ |
| D | package-info.java | 1 package javax.jmdns.impl.tasks;
|
| D | RecordReaper.java | 5 package javax.jmdns.impl.tasks;
|
| /external/jmdns/src/javax/jmdns/impl/tasks/state/ |
| D | package-info.java | 1 package javax.jmdns.impl.tasks.state;
|
| D | DNSStateTask.java | 2 package javax.jmdns.impl.tasks.state;
17 import javax.jmdns.impl.tasks.DNSTask;
|
| /external/eclipse-basebuilder/basebuilder-3.6.2/org.eclipse.releng.basebuilder/plugins/org.eclipse.build.tools/schema/ |
| D | _README.txt | 2 Ant scripts + tasks.
|
| /external/linux-tools-perf/ |
| D | builtin-sched.c | 91 static struct task_desc **tasks; variable
346 tasks = realloc(tasks, nr_tasks*sizeof(struct task_task *)); in register_pid()
347 BUG_ON(!tasks); in register_pid()
348 tasks[task->nr] = task; in register_pid()
363 task = tasks[i]; in print_task_traces()
375 task1 = tasks[i]; in add_cross_task_wakeups()
379 task2 = tasks[j]; in add_cross_task_wakeups()
535 task = tasks[i]; in create_tasks()
556 task = tasks[i]; in wait_for_tasks()
569 task = tasks[i]; in wait_for_tasks()
[all …]
|
| /external/chromium/base/threading/ |
| D | worker_pool_posix_unittest.cc | 28 const std::queue<Task*>& tasks() const { return pool_->tasks_; } in tasks() function in base::PosixDynamicThreadPool::PosixDynamicThreadPoolPeer
183 EXPECT_EQ(0U, peer_.tasks().size()); in TEST_F()
|
| /external/linux-tools-perf/util/ |
| D | event.c | 63 DIR *tasks; in perf_event__synthesize_comm() local
122 tasks = opendir(filename); in perf_event__synthesize_comm()
123 if (tasks == NULL) in perf_event__synthesize_comm()
126 while (!readdir_r(tasks, &dirent, &next) && next) { in perf_event__synthesize_comm()
137 closedir(tasks); in perf_event__synthesize_comm()
|