Package org.flowable.common.spring.async

Class SpringAsyncTaskExecutor

java.lang.Object

org.flowable.common.spring.async.SpringAsyncTaskExecutor

All Implemented Interfaces:

AsyncTaskExecutor

public class SpringAsyncTaskExecutor
extends Object
implements AsyncTaskExecutor

Author:

Filip Hrisafov, Joram Barrez

Field Summary

Fields

Modifier and Type	Field	Description
protected final AsyncTaskExecutor	asyncTaskExecutor
protected final boolean	isAsyncTaskExecutorAopProxied

Constructor Summary

Constructors

Constructor	Description
SpringAsyncTaskExecutor(AsyncTaskExecutor asyncTaskExecutor)

Method Summary

Modifier and Type	Method	Description
void	execute(Runnable task)	Execute the given task
AsyncTaskExecutor	getAsyncTaskExecutor()
int	getRemainingCapacity()
void	shutdown()	Potentially shutdown the resources used by the async task executor.
CompletableFuture<?>	submit(Runnable task)	Submit a Runnable task for execution, receiving a Future representing the execution of the task.
<T> CompletableFuture<T>	submit(Callable<T> task)	Submit a Callable task for execution, receiving a Future representing the execution of the task.

Methods inherited from class java.lang.Object

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

Field Details

asyncTaskExecutor

protected final AsyncTaskExecutor asyncTaskExecutor

isAsyncTaskExecutorAopProxied

protected final boolean isAsyncTaskExecutorAopProxied

Constructor Details

SpringAsyncTaskExecutor

public SpringAsyncTaskExecutor(AsyncTaskExecutor asyncTaskExecutor)

Method Details

execute

public void execute(Runnable task)

Description copied from interface: AsyncTaskExecutor

Execute the given task

Specified by:

execute in interface AsyncTaskExecutor

Parameters:

task - the Runnable task to execute

submit

public CompletableFuture<?> submit(Runnable task)

Description copied from interface: AsyncTaskExecutor

Submit a Runnable task for execution, receiving a Future representing the execution of the task.

Specified by:

submit in interface AsyncTaskExecutor

Parameters:

task - the Runnable to execute

Returns:

a CompletableFuture representing pending completion of the task

submit

public <T> CompletableFuture<T> submit(Callable<T> task)

Description copied from interface: AsyncTaskExecutor

Submit a Callable task for execution, receiving a Future representing the execution of the task.

Specified by:

submit in interface AsyncTaskExecutor

Parameters:

task - the Runnable to execute

Returns:

a CompletableFuture representing pending completion of the task

shutdown

public void shutdown()

Description copied from interface: AsyncTaskExecutor

Potentially shutdown the resources used by the async task executor.

Specified by:

shutdown in interface AsyncTaskExecutor

getAsyncTaskExecutor

public AsyncTaskExecutor getAsyncTaskExecutor()

getRemainingCapacity

public int getRemainingCapacity()

Specified by:

getRemainingCapacity in interface AsyncTaskExecutor