co.paralleluniverse.concurrent.util

Interface CompletableExecutorService

All Superinterfaces:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService

All Known Subinterfaces:

CompletableScheduledExecutorService

All Known Implementing Classes:

AbstractCompletableExecutorService

public interface CompletableExecutorService
extends java.util.concurrent.ExecutorService

Method Summary

Modifier and Type	Method and Description
<T> java.util.List<java.util.concurrent.Future<T>>	invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
<T> java.util.List<java.util.concurrent.Future<T>>	invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, long timeout, java.util.concurrent.TimeUnit unit)
<T> java.util.concurrent.CompletableFuture<T>	submit(java.util.concurrent.Callable<T> task)
java.util.concurrent.CompletableFuture<?>	submit(java.lang.Runnable task)
<T> java.util.concurrent.CompletableFuture<T>	submit(java.lang.Runnable task, T result)

Methods inherited from interface java.util.concurrent.ExecutorService

awaitTermination, invokeAny, invokeAny, isShutdown, isTerminated, shutdown, shutdownNow

Methods inherited from interface java.util.concurrent.Executor

execute

Method Detail

submit

<T> java.util.concurrent.CompletableFuture<T> submit(java.util.concurrent.Callable<T> task)

Specified by:

submit in interface java.util.concurrent.ExecutorService

Returns:

a CompletableFuture representing pending completion of the task

Throws:

RejectedExecutionException

submit

java.util.concurrent.CompletableFuture<?> submit(java.lang.Runnable task)

Specified by:

submit in interface java.util.concurrent.ExecutorService

Returns:

a CompletableFuture representing pending completion of the task

Throws:

RejectedExecutionException

submit

<T> java.util.concurrent.CompletableFuture<T> submit(java.lang.Runnable task,
                                                     T result)

Specified by:

submit in interface java.util.concurrent.ExecutorService

Returns:

a CompletableFuture representing pending completion of the task

Throws:

RejectedExecutionException

invokeAll

<T> java.util.List<java.util.concurrent.Future<T>> invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
                                                      throws java.lang.InterruptedException

All elements in the returned list must be CompletableFuture instances.

Specified by:

invokeAll in interface java.util.concurrent.ExecutorService

Returns:

A list of CompletableFuture instances representing the tasks, in the same sequential order as produced by the iterator for the given task list, each of which has completed.

Throws:

RejectedExecutionException

java.lang.NullPointerException - if any task is null

java.lang.InterruptedException

invokeAll

<T> java.util.List<java.util.concurrent.Future<T>> invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks,
                                                             long timeout,
                                                             java.util.concurrent.TimeUnit unit)
                                                      throws java.lang.InterruptedException

All elements in the returned list must be CompletableFuture instances.

Specified by:

invokeAll in interface java.util.concurrent.ExecutorService

Returns:

a list of CompletableFuture instances representing the tasks, in the same sequential order as produced by the iterator for the given task list. If the operation did not time out, each task will have completed. If it did time out, some of these tasks will not have completed.

Throws:

RejectedExecutionException

java.lang.NullPointerException - if any task is null

java.lang.InterruptedException