类 WorkManagerTaskExecutor

构造器详细资料

• WorkManagerTaskExecutor

  public WorkManagerTaskExecutor()

方法详细资料

• setWorkManager

  public void setWorkManager​(WorkManager workManager)

  Specify the CommonJ WorkManager to delegate to.

  Alternatively, you can also specify the JNDI name of the target WorkManager.

  另请参阅:

  setWorkManagerName(java.lang.String)

• setWorkManagerName

  public void setWorkManagerName​(String workManagerName)

  Set the JNDI name of the CommonJ WorkManager.

  This can either be a fully qualified JNDI name, or the JNDI name relative to the current environment naming context if "resourceRef" is set to "true".

  另请参阅:

  setWorkManager(commonj.work.WorkManager), JndiLocatorSupport.setResourceRef(boolean)

• setWorkListener

  public void setWorkListener​(WorkListener workListener)

  Specify a CommonJ WorkListener to apply, if any.

  This shared WorkListener instance will be passed on to the WorkManager by all execute(java.lang.Runnable) calls on this TaskExecutor.

• setTaskDecorator

  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.

  从以下版本开始:

  4.3

• afterPropertiesSet

  public void afterPropertiesSet()
                          throws NamingException

  从接口复制的说明: InitializingBean
  Invoked by the containing BeanFactory after it has set all bean properties and satisfied BeanFactoryAware, ApplicationContextAware etc.

  This method allows the bean instance to perform validation of its overall configuration and final initialization when all bean properties have been set.

  指定者:

  afterPropertiesSet 在接口中 InitializingBean

  抛出:

  NamingException

• 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

• schedule

  public WorkItem schedule​(Work work)
                    throws WorkException,
                           IllegalArgumentException

  指定者:

  schedule 在接口中 WorkManager

  抛出:

  WorkException

  IllegalArgumentException

• schedule

  public WorkItem schedule​(Work work,
                           WorkListener workListener)
                    throws WorkException

  指定者:

  schedule 在接口中 WorkManager

  抛出:

  WorkException

• waitForAll

  public boolean waitForAll​(Collection workItems,
                            long timeout)
                     throws InterruptedException

  指定者:

  waitForAll 在接口中 WorkManager

  抛出:

  InterruptedException

• waitForAny

  public Collection waitForAny​(Collection workItems,
                               long timeout)
                        throws InterruptedException

  指定者:

  waitForAny 在接口中 WorkManager

  抛出:

  InterruptedException