com.atlassian.plugin.osgi.spring

Class ThreadPoolAsyncTaskExecutor

java.lang.Object

com.atlassian.plugin.osgi.spring.ThreadPoolAsyncTaskExecutor

All Implemented Interfaces:

Executor, org.springframework.core.task.AsyncTaskExecutor, org.springframework.core.task.TaskExecutor

public class ThreadPoolAsyncTaskExecutor
extends Object
implements org.springframework.core.task.AsyncTaskExecutor

Executes spring tasks using a cached thread pool that expands as necessary. Overrides the default Spring executor that spawns a new thread for every application context creation.

Since:

2.5.0

Field Summary

Fields inherited from interface org.springframework.core.task.AsyncTaskExecutor

TIMEOUT_IMMEDIATE, TIMEOUT_INDEFINITE

Constructor Summary

Constructors

Constructor and Description
ThreadPoolAsyncTaskExecutor()

Method Summary

Modifier and Type	Method and Description
void	execute(Runnable task) Executes the runnable
void	execute(Runnable task, long startTimeout) Executes the runnable
void	shutdown() Shuts down the internal ExecutorService to ensure that all threads are stopped in order to allow the JVM to terminate cleanly in a timely fashion.
<T> Future<T>	submit(Callable<T> task)
Future<?>	submit(Runnable task)

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadPoolAsyncTaskExecutor

public ThreadPoolAsyncTaskExecutor()

Method Detail

execute

public void execute(@Nonnull
                    Runnable task,
                    long startTimeout)

Executes the runnable

Specified by:

execute in interface org.springframework.core.task.AsyncTaskExecutor

Parameters:

task - The runnable task

startTimeout - The start timeout (ignored)

submit

@Nonnull
public Future<?> submit(@Nonnull
                                 Runnable task)

Specified by:

submit in interface org.springframework.core.task.AsyncTaskExecutor

submit

@Nonnull
public <T> Future<T> submit(@Nonnull
                                     Callable<T> task)

Specified by:

submit in interface org.springframework.core.task.AsyncTaskExecutor

execute

public void execute(@Nonnull
                    Runnable task)

Executes the runnable

Specified by:

execute in interface Executor

Specified by:

execute in interface org.springframework.core.task.TaskExecutor

Parameters:

task - The runnable task

shutdown

public void shutdown()

Shuts down the internal ExecutorService to ensure that all threads are stopped in order to allow the JVM to terminate cleanly in a timely fashion.