co.paralleluniverse.concurrent.util

Class AbstractCompletableExecutorService

java.lang.Object

java.util.concurrent.AbstractExecutorService

co.paralleluniverse.concurrent.util.AbstractCompletableExecutorService

All Implemented Interfaces:

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

public abstract class AbstractCompletableExecutorService
extends java.util.concurrent.AbstractExecutorService
implements CompletableExecutorService

Implements CompletableExecutorService execution methods atop the abstract Executor.execute(java.lang.Runnable) method. More concretely, the submit, invokeAny and invokeAll methods create CompletableFutureTask instances and pass them to Executor.execute(java.lang.Runnable).

In addition to Executor.execute(java.lang.Runnable), subclasses must implement all methods related to shutdown and termination.

Constructor Summary

Constructors

Constructor and Description
AbstractCompletableExecutorService()

Method Summary

Modifier and Type	Method and Description
protected <T> java.util.concurrent.RunnableFuture<T>	newTaskFor(java.util.concurrent.Callable<T> callable)
protected <T> java.util.concurrent.RunnableFuture<T>	newTaskFor(java.lang.Runnable runnable, T value)
<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 class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface co.paralleluniverse.concurrent.util.CompletableExecutorService

invokeAll, invokeAll

Methods inherited from interface java.util.concurrent.ExecutorService

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

Methods inherited from interface java.util.concurrent.Executor

execute

Constructor Detail

AbstractCompletableExecutorService

public AbstractCompletableExecutorService()

Method Detail

submit

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

Specified by:

submit in interface CompletableExecutorService

Specified by:

submit in interface java.util.concurrent.ExecutorService

Overrides:

submit in class java.util.concurrent.AbstractExecutorService

Returns:

a CompletableFuture representing pending completion of the task

submit

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

Specified by:

submit in interface CompletableExecutorService

Specified by:

submit in interface java.util.concurrent.ExecutorService

Overrides:

submit in class java.util.concurrent.AbstractExecutorService

Returns:

a CompletableFuture representing pending completion of the task

submit

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

Specified by:

submit in interface CompletableExecutorService

Specified by:

submit in interface java.util.concurrent.ExecutorService

Overrides:

submit in class java.util.concurrent.AbstractExecutorService

Returns:

a CompletableFuture representing pending completion of the task

newTaskFor

protected <T> java.util.concurrent.RunnableFuture<T> newTaskFor(java.lang.Runnable runnable,
                                                                T value)

Overrides:

newTaskFor in class java.util.concurrent.AbstractExecutorService

newTaskFor

protected <T> java.util.concurrent.RunnableFuture<T> newTaskFor(java.util.concurrent.Callable<T> callable)

Overrides:

newTaskFor in class java.util.concurrent.AbstractExecutorService