Searched defs:tasks (Results 1 - 5 of 5) sorted by relevance
/libcore/ojluni/src/main/java/java/util/concurrent/ |
H A D | ExecutorService.java | 48 * 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 D | AbstractExecutorService.java | 147 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 D | Executors.java | 83 * {@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 D | ForkJoinTask.java | 52 * 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 D | ForkJoinPool.java | 59 * 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 8 milliseconds