Lines Matching refs:tasks
63 private <T> T doInvokeAny(Collection<? extends Callable<T>> tasks, boolean timed, long nanos)
65 int ntasks = tasks.size();
71 // parallelism, check to see if previously submitted tasks are
81 Iterator<? extends Callable<T>> it = tasks.iterator();
132 @Override public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
135 return doInvokeAny(tasks, false, 0);
142 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
144 return doInvokeAny(tasks, true, unit.toNanos(timeout));
147 @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
149 if (tasks == null) {
152 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size());
155 for (Callable<T> t : tasks) {
181 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
183 if (tasks == null || unit == null) {
187 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size());
190 for (Callable<T> t : tasks) {