Searched defs:tasks (Results 1 - 5 of 5) sorted by relevance

/libcore/ojluni/src/main/java/java/util/concurrent/
H A DExecutorService.java48 * one or more asynchronous tasks.
51 * it to reject new tasks. Two different methods are provided for
53 * method will allow previously submitted tasks to execute before
55 * tasks from starting and attempts to stop currently executing tasks.
56 * Upon termination, an executor has no tasks actively executing, no
57 * tasks awaiting execution, and no new tasks can be submitted. An
66 * tasks and then waiting for at least one, or all, to
110 * first by calling {@code shutdown} to reject incoming tasks, an
277 invokeAll(Collection<? extends Callable<T>> tasks) argument
308 invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument
331 invokeAny(Collection<? extends Callable<T>> tasks) argument
357 invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument
[all...]
H A DAbstractExecutorService.java147 private <T> T doInvokeAny(Collection<? extends Callable<T>> tasks, argument
150 if (tasks == null)
152 int ntasks = tasks.size();
160 // parallelism, check to see if previously submitted tasks are
170 Iterator<? extends Callable<T>> it = tasks.iterator();
217 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) argument
220 return doInvokeAny(tasks, false, 0);
227 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, argument
230 return doInvokeAny(tasks, true, unit.toNanos(timeout));
233 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) argument
259 invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument
[all...]
H A DExecutors.java83 * {@code nThreads} threads will be active processing tasks.
84 * If additional tasks are submitted when all threads are active,
88 * execute subsequent tasks. The threads in the pool will exist
108 * guarantees about the order in which submitted tasks are
144 * tasks. If additional tasks are submitted when all threads are
148 * needed to execute subsequent tasks. The threads in the pool will
170 * subsequent tasks.) Tasks are guaranteed to execute
211 * of programs that execute many short-lived asynchronous tasks.
251 * subsequent tasks
642 invokeAll(Collection<? extends Callable<T>> tasks) argument
646 invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument
651 invokeAny(Collection<? extends Callable<T>> tasks) argument
655 invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) argument
[all...]
H A DForkJoinTask.java52 * Abstract base class for tasks that run within a {@link ForkJoinPool}.
54 * lighter weight than a normal thread. Huge numbers of tasks and
74 * reflecting their main use as computational tasks calculating pure
81 * tasks or using synchronizers such as Phasers that are advertised to
82 * cooperate with fork/join scheduling. Subdividable tasks should also
85 * tasks. These guidelines are loosely enforced by not permitting
100 * of few if any <em>other</em> tasks should be dependent on a task
102 * tasks that are never joined (for example, those subclassing {@link
104 * resource impact, tasks should be small; ideally performing only the
107 * blocked tasks i
772 invokeAll(ForkJoinTask<?>.... tasks) argument
817 invokeAll(Collection<T> tasks) argument
[all...]
H A DForkJoinPool.java59 * execute tasks submitted to the pool and/or created by other active
60 * tasks (eventually blocking waiting for work if none exist). This
61 * enables efficient processing when most tasks spawn other subtasks
63 * tasks are submitted to the pool from external clients. Especially
66 * tasks that are never joined.
80 * threads, even if some tasks are stalled waiting to join others.
100 * tasks that are already executing in a pool should normally instead
102 * async event-style tasks that are not usually joined, in which case
151 * cause unjoined tasks to never be executed.
158 * <p>This implementation rejects submitted tasks (tha
2832 invokeAll(Collection<? extends Callable<T>> tasks) argument
[all...]

Completed in 29 milliseconds