com.bluegosling.concurrent.executors

Interface CompletableExecutorService

All Superinterfaces:

Executor, ExecutorService

public interface CompletableExecutorService
extends ExecutorService

An executor service that returns CompletableFutures.

Method Summary

Modifier and Type	Method and Description
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
static CompletableExecutorService	makeCompletable(ExecutorService executor) Converts the specified service into a CompletableExecutorService.
static CompletableExecutorService	sameThreadExecutorService() Returns a new executor service that runs each task synchronously in the same thread that submits it.
<T> CompletableFuture<T>	submit(Callable<T> task)
CompletableFuture<Void>	submit(Runnable task)
<T> CompletableFuture<T>	submit(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> CompletableFuture<T> submit(Callable<T> task)

Overrides the return type to be completable.

Specified by:

submit in interface ExecutorService

submit

<T> CompletableFuture<T> submit(Runnable task,
                                T result)

Overrides the return type to be completable.

Specified by:

submit in interface ExecutorService

submit

CompletableFuture<Void> submit(Runnable task)

Overrides the return type to be completable.

Specified by:

submit in interface ExecutorService

invokeAll

<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
                       throws InterruptedException

Every instance in the returned list will be an instance of CompletableFuture.

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

invokeAll

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

Every instance in the returned list will be an instance of CompletableFuture.

Specified by:

invokeAll in interface ExecutorService

Throws:

InterruptedException

sameThreadExecutorService

static CompletableExecutorService sameThreadExecutorService()

Returns a new executor service that runs each task synchronously in the same thread that submits it. Submissions that return futures will always return completed futures.

Returns:

a new executor service that runs tasks immediately in the current thread

makeCompletable

static CompletableExecutorService makeCompletable(ExecutorService executor)

Converts the specified service into a CompletableExecutorService. If the specified service is already completable, it is returned without any conversion.

Instances of CompletableFuture returned from the executor's various submit methods differ from typical completable futures in that a call to future.cancel(true) will attempt to interrupt the thread that is running the associated task. (See CompletableFutures.callInterruptiblyAsync(Callable, Executor).)

Parameters:

executor - the executor service

Returns:

a completable version of the specified service