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 and Description
protected org.springframework.core.task.AsyncListenableTaskExecutor	asyncTaskExecutor
protected boolean	isAsyncTaskExecutorAopProxied

Constructor Summary

Constructors

Constructor and Description
SpringAsyncTaskExecutor(org.springframework.core.task.AsyncListenableTaskExecutor asyncTaskExecutor)

Method Summary

Modifier and Type	Method and Description
void	execute(Runnable task) Execute the given task
org.springframework.core.task.AsyncListenableTaskExecutor	getAsyncTaskExecutor()
int	getRemainingCapacity()
void	shutdown() Potentially shutdown the resources used by the async task executor.
<T> CompletableFuture<T>	submit(Callable<T> task) Submit a Callable task for execution, receiving a Future representing the execution of the task.
CompletableFuture<?>	submit(Runnable task) Submit a Runnable 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 Detail

asyncTaskExecutor

protected final org.springframework.core.task.AsyncListenableTaskExecutor asyncTaskExecutor

isAsyncTaskExecutorAopProxied

protected final boolean isAsyncTaskExecutorAopProxied

Constructor Detail

SpringAsyncTaskExecutor

public SpringAsyncTaskExecutor(org.springframework.core.task.AsyncListenableTaskExecutor asyncTaskExecutor)

Method Detail

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 org.springframework.core.task.AsyncListenableTaskExecutor getAsyncTaskExecutor()

getRemainingCapacity

public int getRemainingCapacity()

Specified by:

getRemainingCapacity in interface AsyncTaskExecutor