Home | History | Annotate | Download | only in concurrent

Lines Matching refs:Future

53  *     List<Future<Result>> futures
54 * = new ArrayList<Future<Result>>(n);
70 * for (Future<Result> f : futures)
81 private final BlockingQueue<Future<V>> completionQueue;
92 private final Future<V> task;
123 this.completionQueue = new LinkedBlockingQueue<Future<V>>();
140 BlockingQueue<Future<V>> completionQueue) {
149 public Future<V> submit(Callable<V> task) {
156 public Future<V> submit(Runnable task, V result) {
163 public Future<V> take() throws InterruptedException {
167 public Future<V> poll() {
171 public Future<V> poll(long timeout, TimeUnit unit)