java.lang.Object
- org.springframework.scheduling.concurrent.ConcurrentTaskExecutor

所有已实现的接口:
Executor, AsyncListenableTaskExecutor, AsyncTaskExecutor, TaskExecutor, SchedulingTaskExecutor
直接已知子类:
ConcurrentTaskScheduler, DefaultManagedTaskExecutor
```
public class ConcurrentTaskExecutor
extends Object
implements AsyncListenableTaskExecutor, SchedulingTaskExecutor
```
Adapter that takes a java.util.concurrent.Executor and exposes a Spring TaskExecutor for it. Also detects an extended java.util.concurrent.ExecutorService, adapting the AsyncTaskExecutor interface accordingly.
Autodetects a JSR-236 ManagedExecutorService in order to expose ManagedTask adapters for it, exposing a long-running hint based on SchedulingAwareRunnable and an identity name based on the given Runnable/Callable's toString(). For JSR-236 style lookup in a Java EE 7 environment, consider using DefaultManagedTaskExecutor.
Note that there is a pre-built ThreadPoolTaskExecutor that allows for defining a ThreadPoolExecutor in bean style, exposing it as a Spring TaskExecutor directly. This is a convenient alternative to a raw ThreadPoolExecutor definition with a separate definition of the present adapter class.
从以下版本开始:
2.0
作者:
Juergen Hoeller
另请参阅:
Executor, ExecutorService, ThreadPoolExecutor, Executors, DefaultManagedTaskExecutor, ThreadPoolTaskExecutor

嵌套类概要

嵌套类
修饰符和类型	类	说明
`protected static class`	`ConcurrentTaskExecutor.ManagedTaskBuilder`	Delegate that wraps a given Runnable/Callable with a JSR-236 ManagedTask, exposing a long-running hint based on `SchedulingAwareRunnable` and a given identity name.

字段概要
- 从接口继承的字段 org.springframework.core.task.AsyncTaskExecutor
  TIMEOUT_IMMEDIATE, TIMEOUT_INDEFINITE

构造器概要

构造器
构造器	说明
`ConcurrentTaskExecutor()`	Create a new ConcurrentTaskExecutor, using a single thread executor as default.
`ConcurrentTaskExecutor(Executor executor)`	Create a new ConcurrentTaskExecutor, using the given `Executor`.

方法概要

所有方法实例方法具体方法
修饰符和类型	方法	说明
`void`	`execute(Runnable task)`	Execute the given `task`.
`void`	`execute(Runnable task, long startTimeout)`	Execute the given `task`.
`Executor`	`getConcurrentExecutor()`	Return the `Executor` that this adapter delegates to.
`void`	`setConcurrentExecutor(Executor executor)`	Specify the `Executor` to delegate to.
`void`	`setTaskDecorator(TaskDecorator taskDecorator)`	Specify a custom `TaskDecorator` to be applied to any `Runnable` about to be executed.
`Future<?>`	`submit(Runnable task)`	Submit a Runnable task for execution, receiving a Future representing that task.
`<T> Future<T>`	`submit(Callable<T> task)`	Submit a Callable task for execution, receiving a Future representing that task.
`ListenableFuture<?>`	`submitListenable(Runnable task)`	Submit a `Runnable` task for execution, receiving a `ListenableFuture` representing that task.
`<T> ListenableFuture<T>`	`submitListenable(Callable<T> task)`	Submit a `Callable` task for execution, receiving a `ListenableFuture` representing that task.

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.springframework.scheduling.SchedulingTaskExecutor
prefersShortLivedTasks

- 构造器详细资料
  - ConcurrentTaskExecutor
```
public ConcurrentTaskExecutor()
```
    Create a new ConcurrentTaskExecutor, using a single thread executor as default.
    另请参阅:
    Executors.newSingleThreadExecutor()
  - ConcurrentTaskExecutor
```
public ConcurrentTaskExecutor(@Nullable
                              Executor executor)
```
    Create a new ConcurrentTaskExecutor, using the given Executor.
    Autodetects a JSR-236 ManagedExecutorService in order to expose ManagedTask adapters for it.
    参数:
    executor - the Executor to delegate to
- 方法详细资料
  - setConcurrentExecutor
```
public final void setConcurrentExecutor(@Nullable
                                        Executor executor)
```
    Specify the Executor to delegate to.
    Autodetects a JSR-236 ManagedExecutorService in order to expose ManagedTask adapters for it.
  - getConcurrentExecutor
```
public final Executor getConcurrentExecutor()
```
    Return the Executor that this adapter delegates to.
  - setTaskDecorator
```
public final 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.
    从以下版本开始:
    4.3
  - execute
```
public void execute(Runnable task)
```
    从接口复制的说明: TaskExecutor
    Execute the given task.
    The call might return immediately if the implementation uses an asynchronous execution strategy, or might block in the case of synchronous execution.
    指定者:
    execute 在接口中 Executor
    指定者:
    execute 在接口中 TaskExecutor
    参数:
    task - the Runnable to execute (never null)
  - execute
```
public void execute(Runnable task,
                    long startTimeout)
```
    从接口复制的说明: AsyncTaskExecutor
    Execute the given task.
    指定者:
    execute 在接口中 AsyncTaskExecutor
    参数:
    task - the Runnable to execute (never null)
    startTimeout - 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 AsyncTaskExecutor.TIMEOUT_IMMEDIATE or AsyncTaskExecutor.TIMEOUT_INDEFINITE (the default as used by TaskExecutor.execute(Runnable)).
  - submit
```
public Future<?> submit(Runnable task)
```
    从接口复制的说明: AsyncTaskExecutor
    Submit a Runnable task for execution, receiving a Future representing that task. The Future will return a null result upon completion.
    指定者:
    submit 在接口中 AsyncTaskExecutor
    参数:
    task - the Runnable to execute (never null)
    返回:
    a Future representing pending completion of the task
  - submit
```
public <T> Future<T> submit(Callable<T> task)
```
    从接口复制的说明: AsyncTaskExecutor
    Submit a Callable task for execution, receiving a Future representing that task. The Future will return the Callable's result upon completion.
    指定者:
    submit 在接口中 AsyncTaskExecutor
    参数:
    task - the Callable to execute (never null)
    返回:
    a Future representing pending completion of the task
  - submitListenable
```
public ListenableFuture<?> submitListenable(Runnable task)
```
    从接口复制的说明: AsyncListenableTaskExecutor
    Submit a Runnable task for execution, receiving a ListenableFuture representing that task. The Future will return a null result upon completion.
    指定者:
    submitListenable 在接口中 AsyncListenableTaskExecutor
    参数:
    task - the Runnable to execute (never null)
    返回:
    a ListenableFuture representing pending completion of the task
  - submitListenable
```
public <T> ListenableFuture<T> submitListenable(Callable<T> task)
```
    从接口复制的说明: AsyncListenableTaskExecutor
    Submit a Callable task for execution, receiving a ListenableFuture representing that task. The Future will return the Callable's result upon completion.
    指定者:
    submitListenable 在接口中 AsyncListenableTaskExecutor
    参数:
    task - the Callable to execute (never null)
    返回:
    a ListenableFuture representing pending completion of the task

类 ConcurrentTaskExecutor

嵌套类概要

字段概要

从接口继承的字段 org.springframework.core.task.AsyncTaskExecutor

构造器概要

方法概要

从类继承的方法 java.lang.Object

从接口继承的方法 org.springframework.scheduling.SchedulingTaskExecutor

构造器详细资料

ConcurrentTaskExecutor

ConcurrentTaskExecutor

方法详细资料

setConcurrentExecutor

getConcurrentExecutor

setTaskDecorator

execute

execute

submit

submit

submitListenable

submitListenable