类 ConcurrentTaskExecutor

构造器详细资料

• ConcurrentTaskExecutor

  public ConcurrentTaskExecutor()

  Create a new ConcurrentTaskExecutor, using a single thread executor as default.

  另请参阅:

  Executors.newSingleThreadExecutor()

• ConcurrentTaskExecutor

  public ConcurrentTaskExecutor​(Executor concurrentExecutor)

  Create a new ConcurrentTaskExecutor, using the given Executor.

  Autodetects a JSR-236 ManagedExecutorService in order to expose ManagedTask adapters for it.

  参数:

  concurrentExecutor - the Executor to delegate to

方法详细资料

• setConcurrentExecutor

  public final void setConcurrentExecutor​(Executor concurrentExecutor)

  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

• prefersShortLivedTasks

  public boolean prefersShortLivedTasks()

  This task executor prefers short-lived work units.

  指定者:

  prefersShortLivedTasks 在接口中 SchedulingTaskExecutor

  返回:

  true if this TaskExecutor prefers short-lived tasks