Spring Framework 6.1.4 · org.springframework.core.task.SimpleAsyncTaskExecutor

Modifier and Type	Class and Description
private static class	SimpleAsyncTaskExecutor.ConcurrencyThrottleAdapter Subclass of the general ConcurrencyThrottleSupport class, making `beforeAccess()` and `afterAccess()` visible to the surrounding class.
private class	SimpleAsyncTaskExecutor.TaskTrackingRunnable Decorates a target task with active thread tracking and concurrency throttle management, if necessary.

Field Summary

Modifier and Type	Field and Description
private volatile boolean	active
private Set<Thread>	activeThreads
private final SimpleAsyncTaskExecutor.ConcurrencyThrottleAdapter	concurrencyThrottle Internal concurrency throttle used by this executor.
public static final int	NO_CONCURRENCY Switch concurrency 'off': that is, don't allow any concurrent invocations.
private TaskDecorator	taskDecorator
private long	taskTerminationTimeout
private ThreadFactory	threadFactory
public static final int	UNBOUNDED_CONCURRENCY Permit any number of concurrent invocations: that is, don't throttle concurrency.
private VirtualThreadDelegate	virtualThreadDelegate

Constructor Summary

Access	Constructor and Description
public	SimpleAsyncTaskExecutor() Create a new SimpleAsyncTaskExecutor with default thread name prefix.
public	SimpleAsyncTaskExecutor(String the prefix to use for the names of newly created threads threadNamePrefix) Create a new SimpleAsyncTaskExecutor with the given thread name prefix.
public	SimpleAsyncTaskExecutor(ThreadFactory the factory to use for creating new Threads threadFactory) Create a new SimpleAsyncTaskExecutor with the given external thread factory.

Method Summary

Modifier and Type	Method and Description
public void	close() Implements java.lang.AutoCloseable.close. This close methods tracks the termination of active threads if a concrete `task termination timeout` has been set.
protected void	doExecute(Runnable the Runnable to execute task) Template method for the actual execution of a task.
public void	execute(Runnable the `Runnable` to execute (never `null`) task) Implements org.springframework.core.task.TaskExecutor.execute. Executes the given task, within a concurrency throttle if configured (through the superclass's settings).
public void	execute(Runnable the `Runnable` to execute (never `null`) task, long the time duration (milliseconds) within which the task is supposed to start. This is intended as a hint to the executor, allowing for preferred handling of immediate tasks. Typical values are `TIMEOUT_IMMEDIATE` or `TIMEOUT_INDEFINITE` (the default as used by `execute(Runnable)`). startTimeout) Overrides default org.springframework.core.task.AsyncTaskExecutor.execute. Deprecated Executes the given task, within a concurrency throttle if configured (through the superclass's settings).
public final int	getConcurrencyLimit() Return the maximum number of parallel task executions allowed.
public final ThreadFactory	getThreadFactory() Return the external factory to use for creating new Threads, if any.
public boolean	isActive() Return whether this executor is still active, i.e. not closed yet, and therefore accepts further task submissions.
public final boolean	Returns: `true` if the concurrency limit for this instance is active isThrottleActive() Return whether the concurrency throttle is currently active.
protected Thread	Returns: the new Thread instance newThread(Runnable the Runnable to create a Thread for task) Create a new Thread for the given task.
public void	setConcurrencyLimit(int concurrencyLimit) Set the maximum number of parallel task executions allowed.
public void	setTaskDecorator(TaskDecorator taskDecorator) Specify a custom `TaskDecorator` to be applied to any `Runnable` about to be executed.
public void	setTaskTerminationTimeout(long the timeout in milliseconds timeout) Specify a timeout (in milliseconds) for task termination when closing this executor.
public void	setThreadFactory(ThreadFactory threadFactory) Specify an external factory to use for creating new Threads, instead of relying on the local properties of this executor.
public void	setVirtualThreads(boolean virtual) Switch this executor to virtual threads.
public Future<?>	submit(Runnable the `Runnable` to execute (never `null`) task) Overrides default org.springframework.core.task.AsyncTaskExecutor.submit. Submit a Runnable task for execution, receiving a Future representing that task.
public <T> Future<T>	submit(Callable<T> the `Callable` to execute (never `null`) task) Overrides default org.springframework.core.task.AsyncTaskExecutor.submit. Submit a Callable task for execution, receiving a Future representing that task.
public ListenableFuture<?>	submitListenable(Runnable the `Runnable` to execute (never `null`) task) Implements org.springframework.core.task.AsyncListenableTaskExecutor.submitListenable. References Deprecated `ListenableFuture` is deprecated or references (maybe indirectly) at least one deprecated element. Submit a `Runnable` task for execution, receiving a `ListenableFuture` representing that task.
public <T> ListenableFuture<T>	submitListenable(Callable<T> the `Callable` to execute (never `null`) task) Implements org.springframework.core.task.AsyncListenableTaskExecutor.submitListenable. References Deprecated `ListenableFuture` is deprecated or references (maybe indirectly) at least one deprecated element. Submit a `Callable` task for execution, receiving a `ListenableFuture` representing that task.

Inherited from org.springframework.util.CustomizableThreadCreator:: createThread getDefaultThreadNamePrefix getThreadGroup getThreadNamePrefix getThreadPriority isDaemon nextThreadName setDaemon setThreadGroup setThreadGroupName setThreadNamePrefix setThreadPriority

Field Detail

active	back to summary
private volatile boolean active

activeThreads	back to summary
private Set<Thread> activeThreads Annotations @Nullable

concurrencyThrottle	back to summary
private final SimpleAsyncTaskExecutor.ConcurrencyThrottleAdapter concurrencyThrottle Internal concurrency throttle used by this executor.

NO_CONCURRENCY back to summary

NO_CONCURRENCY	back to summary
public static final int NO_CONCURRENCY Switch concurrency 'off': that is, don't allow any concurrent invocations. See Also `ConcurrencyThrottleSupport#NO_CONCURRENCY`

public static final int NO_CONCURRENCY

Switch concurrency 'off': that is, don't allow any concurrent invocations.

See Also: ConcurrencyThrottleSupport#NO_CONCURRENCY

taskDecorator	back to summary
private TaskDecorator taskDecorator Annotations @Nullable

taskTerminationTimeout	back to summary
private long taskTerminationTimeout

threadFactory	back to summary
private ThreadFactory threadFactory Annotations @Nullable

UNBOUNDED_CONCURRENCY back to summary

UNBOUNDED_CONCURRENCY	back to summary
public static final int UNBOUNDED_CONCURRENCY Permit any number of concurrent invocations: that is, don't throttle concurrency. See Also `ConcurrencyThrottleSupport#UNBOUNDED_CONCURRENCY`

public static final int UNBOUNDED_CONCURRENCY

Permit any number of concurrent invocations: that is, don't throttle concurrency.

See Also: ConcurrencyThrottleSupport#UNBOUNDED_CONCURRENCY

virtualThreadDelegate	back to summary
private VirtualThreadDelegate virtualThreadDelegate Annotations @Nullable

Constructor Detail

SimpleAsyncTaskExecutor	back to summary
public SimpleAsyncTaskExecutor() Create a new SimpleAsyncTaskExecutor with default thread name prefix.

SimpleAsyncTaskExecutor	back to summary
public SimpleAsyncTaskExecutor(String threadNamePrefix) Create a new SimpleAsyncTaskExecutor with the given thread name prefix. Parameters threadNamePrefix:String the prefix to use for the names of newly created threads

SimpleAsyncTaskExecutor

back to summary

public SimpleAsyncTaskExecutor(String threadNamePrefix)

Create a new SimpleAsyncTaskExecutor with the given thread name prefix.

Parameters

threadNamePrefix:String: the prefix to use for the names of newly created threads

SimpleAsyncTaskExecutor	back to summary
public SimpleAsyncTaskExecutor(ThreadFactory threadFactory) Create a new SimpleAsyncTaskExecutor with the given external thread factory. Parameters threadFactory:ThreadFactory the factory to use for creating new Threads

SimpleAsyncTaskExecutor

back to summary

public SimpleAsyncTaskExecutor(ThreadFactory threadFactory)

Create a new SimpleAsyncTaskExecutor with the given external thread factory.

Parameters

threadFactory:ThreadFactory: the factory to use for creating new Threads

Method Detail

close back to summary

close	back to summary
public void close() Implements java.lang.AutoCloseable.close. This close methods tracks the termination of active threads if a concrete `task termination timeout` has been set. Otherwise, it is not necessary to close this executor. Annotations @Override Since 6.1

public void close()

Implements java.lang.AutoCloseable.close.

This close methods tracks the termination of active threads if a concrete task termination timeout has been set. Otherwise, it is not necessary to close this executor.

Annotations

@Override

Since

6.1

doExecute back to summary

doExecute	back to summary
protected void doExecute(Runnable task) Template method for the actual execution of a task. The default implementation creates a new Thread and starts it. Parameters task:Runnable the Runnable to execute See Also `newThread`, `Thread#start()`

protected void doExecute(Runnable task)

Template method for the actual execution of a task.

The default implementation creates a new Thread and starts it.

Parameters

task:Runnable: the Runnable to execute

See Also

newThread, Thread#start()

execute back to summary

execute	back to summary
public void execute(Runnable task) Implements org.springframework.core.task.TaskExecutor.execute. Executes the given task, within a concurrency throttle if configured (through the superclass's settings). Parameters task:Runnable Doc from org.springframework.core.task.TaskExecutor.execute. the `Runnable` to execute (never `null`) Annotations @SuppressWarnings:deprecation @Override See Also `doExecute(Runnable)`

public void execute(Runnable task)

Implements org.springframework.core.task.TaskExecutor.execute.

Executes the given task, within a concurrency throttle if configured (through the superclass's settings).

Parameters

task:Runnable

Doc from org.springframework.core.task.TaskExecutor.execute.

the Runnable to execute (never null)

Annotations

@SuppressWarnings:deprecation
@Override

See Also

doExecute(Runnable)

execute back to summary

execute	back to summary
public void execute(Runnable task, long startTimeout) Overrides default org.springframework.core.task.AsyncTaskExecutor.execute. Deprecated Executes the given task, within a concurrency throttle if configured (through the superclass's settings). Executes urgent tasks (with 'immediate' timeout) directly, bypassing the concurrency throttle (if active). All other tasks are subject to throttling. Parameters task:Runnable Doc from org.springframework.core.task.AsyncTaskExecutor.execute. the `Runnable` to execute (never `null`) startTimeout:long Doc from org.springframework.core.task.AsyncTaskExecutor.execute. the time duration (milliseconds) within which the task is supposed to start. This is intended as a hint to the executor, allowing for preferred handling of immediate tasks. Typical values are `TIMEOUT_IMMEDIATE` or `TIMEOUT_INDEFINITE` (the default as used by `execute(Runnable)`). Annotations @Deprecated @Override See Also `TIMEOUT_IMMEDIATE`, `doExecute(Runnable)`

public void execute(Runnable task, long startTimeout)

Overrides default org.springframework.core.task.AsyncTaskExecutor.execute.

Deprecated

Executes the given task, within a concurrency throttle if configured (through the superclass's settings).

Executes urgent tasks (with 'immediate' timeout) directly, bypassing the concurrency throttle (if active). All other tasks are subject to throttling.

Parameters

task:Runnable

Doc from org.springframework.core.task.AsyncTaskExecutor.execute.

the Runnable to execute (never null)

startTimeout:long

Doc from org.springframework.core.task.AsyncTaskExecutor.execute.

the time duration (milliseconds) within which the task is supposed to start. This is intended as a hint to the executor, allowing for preferred handling of immediate tasks. Typical values are TIMEOUT_IMMEDIATE or TIMEOUT_INDEFINITE (the default as used by execute(Runnable)).

Annotations

@Deprecated
@Override

getConcurrencyLimit	back to summary
public final int getConcurrencyLimit() Return the maximum number of parallel task executions allowed.

getThreadFactory	back to summary
public final ThreadFactory getThreadFactory() Return the external factory to use for creating new Threads, if any. Annotations @Nullable

getThreadFactory

back to summary

public final ThreadFactory getThreadFactory()

Return the external factory to use for creating new Threads, if any.

Annotations

@Nullable

isActive back to summary

isActive	back to summary
public boolean isActive() Return whether this executor is still active, i.e. not closed yet, and therefore accepts further task submissions. Otherwise, it is either in the task termination phase or entirely shut down already. Since 6.1 See Also `setTaskTerminationTimeout`, `close()`

public boolean isActive()

Return whether this executor is still active, i.e. not closed yet, and therefore accepts further task submissions. Otherwise, it is either in the task termination phase or entirely shut down already.

Since: 6.1
See Also: setTaskTerminationTimeout, close()

isThrottleActive back to summary

isThrottleActive	back to summary
public final boolean isThrottleActive() Return whether the concurrency throttle is currently active. Returns:boolean `true` if the concurrency limit for this instance is active See Also `getConcurrencyLimit()`, `setConcurrencyLimit`

public final boolean isThrottleActive()

Return whether the concurrency throttle is currently active.

Returns:boolean: true if the concurrency limit for this instance is active
See Also: getConcurrencyLimit(), setConcurrencyLimit

newThread back to summary

newThread	back to summary
protected Thread newThread(Runnable task) Create a new Thread for the given task. Parameters task:Runnable the Runnable to create a Thread for Returns:Thread the new Thread instance Since 6.1 See Also `setVirtualThreads`, `setThreadFactory`, `createThread`

protected Thread newThread(Runnable task)

Create a new Thread for the given task.

Parameters

task:Runnable: the Runnable to create a Thread for

Returns:Thread

the new Thread instance

Since

6.1

setConcurrencyLimit back to summary

setConcurrencyLimit	back to summary
public void setConcurrencyLimit(int concurrencyLimit) Set the maximum number of parallel task executions allowed. The default of -1 indicates no concurrency limit at all. This is the equivalent of a maximum pool size in a thread pool, preventing temporary overload of the thread management system. See Also `UNBOUNDED_CONCURRENCY`, `org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor#setMaxPoolSize`

public void setConcurrencyLimit(int concurrencyLimit)

Set the maximum number of parallel task executions allowed. The default of -1 indicates no concurrency limit at all.

This is the equivalent of a maximum pool size in a thread pool, preventing temporary overload of the thread management system.

See Also: UNBOUNDED_CONCURRENCY, org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor#setMaxPoolSize

setTaskDecorator back to summary

setTaskDecorator	back to summary
public void setTaskDecorator(TaskDecorator taskDecorator) Specify a custom `TaskDecorator` to be applied to any `Runnable` about to be executed. Note that such a decorator is not necessarily being applied to the user-supplied `Runnable`/`Callable` but rather to the actual execution callback (which may be a wrapper around the user-supplied task). The primary use case is to set some execution context around the task's invocation, or to provide some monitoring/statistics for task execution. Note Exception handling in `TaskDecorator` implementations is limited to plain `Runnable` execution via `execute` calls. In case of `#submit` calls, the exposed `Runnable` will be a `FutureTask` which does not propagate any exceptions; you might have to cast it and call `Future#get` to evaluate exceptions. Since 4.3

public void setTaskDecorator(TaskDecorator taskDecorator)

Specify a custom TaskDecorator to be applied to any Runnable about to be executed.

Note that such a decorator is not necessarily being applied to the user-supplied Runnable/Callable but rather to the actual execution callback (which may be a wrapper around the user-supplied task).

The primary use case is to set some execution context around the task's invocation, or to provide some monitoring/statistics for task execution.

Note

Exception handling in TaskDecorator implementations is limited to plain Runnable execution via execute calls. In case of #submit calls, the exposed Runnable will be a FutureTask which does not propagate any exceptions; you might have to cast it and call Future#get to evaluate exceptions.

Since: 4.3

setTaskTerminationTimeout back to summary

setTaskTerminationTimeout	back to summary
public void setTaskTerminationTimeout(long timeout) Specify a timeout (in milliseconds) for task termination when closing this executor. The default is 0, not waiting for task termination at all. Note that a concrete >0 timeout specified here will lead to the wrapping of every submitted task into a task-tracking runnable which involves considerable overhead in case of a high number of tasks. However, for a modest level of submissions with longer-running tasks, this is feasible in order to arrive at a graceful shutdown. Note that `SimpleAsyncTaskExecutor` does not participate in a coordinated lifecycle stop but rather just awaits task termination on `close()`. Parameters timeout:long the timeout in milliseconds Since 6.1 See Also `close()`, `org.springframework.scheduling.concurrent.ExecutorConfigurationSupport#setAwaitTerminationMillis`

public void setTaskTerminationTimeout(long timeout)

Specify a timeout (in milliseconds) for task termination when closing this executor. The default is 0, not waiting for task termination at all.

Note that a concrete >0 timeout specified here will lead to the wrapping of every submitted task into a task-tracking runnable which involves considerable overhead in case of a high number of tasks. However, for a modest level of submissions with longer-running tasks, this is feasible in order to arrive at a graceful shutdown.

Note that SimpleAsyncTaskExecutor does not participate in a coordinated lifecycle stop but rather just awaits task termination on close().

Parameters

timeout:long: the timeout in milliseconds

Since

6.1

setThreadFactory back to summary

setThreadFactory	back to summary
public void setThreadFactory(ThreadFactory threadFactory) Specify an external factory to use for creating new Threads, instead of relying on the local properties of this executor. You may specify an inner ThreadFactory bean or also a ThreadFactory reference obtained from JNDI (on a Jakarta EE server) or some other lookup mechanism. See Also `setThreadNamePrefix`, `setThreadPriority`

public void setThreadFactory(ThreadFactory threadFactory)

Specify an external factory to use for creating new Threads, instead of relying on the local properties of this executor.

You may specify an inner ThreadFactory bean or also a ThreadFactory reference obtained from JNDI (on a Jakarta EE server) or some other lookup mechanism.

See Also: setThreadNamePrefix, setThreadPriority

setVirtualThreads back to summary

setVirtualThreads	back to summary
public void setVirtualThreads(boolean virtual) Switch this executor to virtual threads. Requires Java 21 or higher. The default is `false`, indicating platform threads. Set this flag to `true` in order to create virtual threads instead. Since 6.1

public void setVirtualThreads(boolean virtual)

Switch this executor to virtual threads. Requires Java 21 or higher.

The default is false, indicating platform threads. Set this flag to true in order to create virtual threads instead.

Since: 6.1

submit back to summary

submit	back to summary
public Future<?> submit(Runnable task) Overrides default org.springframework.core.task.AsyncTaskExecutor.submit. Doc from org.springframework.core.task.AsyncTaskExecutor.submit. Submit a Runnable task for execution, receiving a Future representing that task. The Future will return a `null` result upon completion. As of 6.1, this method comes with a default implementation that delegates to `execute(Runnable)`. Parameters task:Runnable the `Runnable` to execute (never `null`) Returns:Future<?> a Future representing pending completion of the task Annotations @SuppressWarnings:deprecation @Override

public Future<?> submit(Runnable task)

Overrides default org.springframework.core.task.AsyncTaskExecutor.submit.

Doc from org.springframework.core.task.AsyncTaskExecutor.submit.

Submit a Runnable task for execution, receiving a Future representing that task. The Future will return a null result upon completion.

As of 6.1, this method comes with a default implementation that delegates to execute(Runnable).

Parameters

task:Runnable: the Runnable to execute (never null)

Returns:Future<?>

a Future representing pending completion of the task

Annotations

@SuppressWarnings:deprecation
@Override

submit back to summary

submit	back to summary
public <T> Future<T> submit(Callable<T> task) Overrides default org.springframework.core.task.AsyncTaskExecutor.submit. Doc from org.springframework.core.task.AsyncTaskExecutor.submit. Submit a Callable task for execution, receiving a Future representing that task. The Future will return the Callable's result upon completion. As of 6.1, this method comes with a default implementation that delegates to `execute(Runnable)`. Parameters task:Callable<T> the `Callable` to execute (never `null`) Returns:Future<T> a Future representing pending completion of the task Annotations @SuppressWarnings:deprecation @Override

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

Overrides default org.springframework.core.task.AsyncTaskExecutor.submit.

Doc from org.springframework.core.task.AsyncTaskExecutor.submit.

Submit a Callable task for execution, receiving a Future representing that task. The Future will return the Callable's result upon completion.

As of 6.1, this method comes with a default implementation that delegates to execute(Runnable).

Parameters

task:Callable<T>: the Callable to execute (never null)

Returns:Future<T>

a Future representing pending completion of the task

Annotations

@SuppressWarnings:deprecation
@Override

submitListenable back to summary

submitListenable	back to summary
public ListenableFuture<?> submitListenable(Runnable task) Implements org.springframework.core.task.AsyncListenableTaskExecutor.submitListenable. Doc from org.springframework.core.task.AsyncListenableTaskExecutor.submitListenable. References Deprecated `ListenableFuture` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information. Submit a `Runnable` task for execution, receiving a `ListenableFuture` representing that task. The Future will return a `null` result upon completion. Parameters task:Runnable the `Runnable` to execute (never `null`) Returns:ListenableFuture<?> a `ListenableFuture` representing pending completion of the task Annotations @SuppressWarnings:deprecation @Override

public ListenableFuture<?> submitListenable(Runnable task)

Implements org.springframework.core.task.AsyncListenableTaskExecutor.submitListenable.

Doc from org.springframework.core.task.AsyncListenableTaskExecutor.submitListenable.

References Deprecated

ListenableFuture is deprecated or references (maybe indirectly) at least one deprecated element.

See corresponding docs for further information.

Submit a Runnable task for execution, receiving a ListenableFuture representing that task. The Future will return a null result upon completion.

Parameters

task:Runnable: the Runnable to execute (never null)

Returns:ListenableFuture<?>

a ListenableFuture representing pending completion of the task

Annotations

@SuppressWarnings:deprecation
@Override

submitListenable back to summary

submitListenable	back to summary
public <T> ListenableFuture<T> submitListenable(Callable<T> task) Implements org.springframework.core.task.AsyncListenableTaskExecutor.submitListenable. Doc from org.springframework.core.task.AsyncListenableTaskExecutor.submitListenable. References Deprecated `ListenableFuture` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information. Submit a `Callable` task for execution, receiving a `ListenableFuture` representing that task. The Future will return the Callable's result upon completion. Parameters task:Callable<T> the `Callable` to execute (never `null`) Returns:ListenableFuture<T> a `ListenableFuture` representing pending completion of the task Annotations @SuppressWarnings:deprecation @Override

public <T> ListenableFuture<T> submitListenable(Callable<T> task)

Implements org.springframework.core.task.AsyncListenableTaskExecutor.submitListenable.

Doc from org.springframework.core.task.AsyncListenableTaskExecutor.submitListenable.

References Deprecated

ListenableFuture is deprecated or references (maybe indirectly) at least one deprecated element.

See corresponding docs for further information.

Submit a Callable task for execution, receiving a ListenableFuture representing that task. The Future will return the Callable's result upon completion.

Parameters

task:Callable<T>: the Callable to execute (never null)

Returns:ListenableFuture<T>

a ListenableFuture representing pending completion of the task

Annotations

@SuppressWarnings:deprecation
@Override

Access	Constructor and Description
private	ConcurrencyThrottleAdapter()

Method Summary

Modifier and Type	Method and Description
protected void	afterAccess() Overrides org.springframework.util.ConcurrencyThrottleSupport.afterAccess. To be invoked after the main execution logic of concrete subclasses.
protected void	beforeAccess() Overrides org.springframework.util.ConcurrencyThrottleSupport.beforeAccess. To be invoked before the main execution logic of concrete subclasses.

Inherited from org.springframework.util.ConcurrencyThrottleSupport:: getConcurrencyLimit isThrottleActive setConcurrencyLimit

Constructor Detail

ConcurrencyThrottleAdapter	back to summary
private ConcurrencyThrottleAdapter()

Method Detail

afterAccess	back to summary
protected void afterAccess() Overrides org.springframework.util.ConcurrencyThrottleSupport.afterAccess. Doc from org.springframework.util.ConcurrencyThrottleSupport.afterAccess. To be invoked after the main execution logic of concrete subclasses. Annotations @Override

afterAccess

back to summary

protected void afterAccess()

Overrides org.springframework.util.ConcurrencyThrottleSupport.afterAccess.

Doc from org.springframework.util.ConcurrencyThrottleSupport.afterAccess.

To be invoked after the main execution logic of concrete subclasses.

Annotations

@Override

beforeAccess	back to summary
protected void beforeAccess() Overrides org.springframework.util.ConcurrencyThrottleSupport.beforeAccess. Doc from org.springframework.util.ConcurrencyThrottleSupport.beforeAccess. To be invoked before the main execution logic of concrete subclasses. This implementation applies the concurrency throttle. Annotations @Override

beforeAccess

back to summary

protected void beforeAccess()

Overrides org.springframework.util.ConcurrencyThrottleSupport.beforeAccess.

Doc from org.springframework.util.ConcurrencyThrottleSupport.beforeAccess.

To be invoked before the main execution logic of concrete subclasses.

This implementation applies the concurrency throttle.

Annotations

@Override

Modifier and Type	Field and Description
private final Runnable	task

Constructor Summary

Access	Constructor and Description
public	TaskTrackingRunnable(Runnable task)

Method Summary

Modifier and Type	Method and Description
public void	run() Implements java.lang.Runnable.run. Runs this operation.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

task	back to summary
private final Runnable task

Constructor Detail

TaskTrackingRunnable	back to summary
public TaskTrackingRunnable(Runnable task)

Method Detail

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

public Class SimpleAsyncTaskExecutor

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class SimpleAsyncTaskExecutor.ConcurrencyThrottleAdapter

Field Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail

private Class SimpleAsyncTaskExecutor.TaskTrackingRunnable

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail