public abstract class AbstractExecutorServices extends Object implements ExecutorServices
ExecutorServices
.ExecutorServices.TaskFactory<T>
Constructor and Description |
---|
AbstractExecutorServices() |
Modifier and Type | Method and Description |
---|---|
protected <T> List<Future<T>> |
checkForExceptions(List<Future<T>> futures) |
void |
cleanup()
Called by Weld when it is shutting down, allowing the service to perform any cleanup needed.
|
protected abstract int |
getThreadPoolSize() |
<T> List<Future<T>> |
invokeAllAndCheckForExceptions(Collection<? extends Callable<T>> tasks)
Executes the given tasks and blocks until they all finish.
|
<T> List<Future<T>> |
invokeAllAndCheckForExceptions(ExecutorServices.TaskFactory<T> factory)
Executes all the tasks returned from calling
ExecutorServices.TaskFactory.createTasks(int) method. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getTaskExecutor
public <T> List<Future<T>> invokeAllAndCheckForExceptions(Collection<? extends Callable<T>> tasks)
ExecutorServices
invokeAllAndCheckForExceptions
in interface ExecutorServices
tasks
- the collection of taskspublic <T> List<Future<T>> invokeAllAndCheckForExceptions(ExecutorServices.TaskFactory<T> factory)
ExecutorServices
ExecutorServices.TaskFactory.createTasks(int)
method. The method is called exactly
once.If a task throws an exception, the exception is rethrown by this method. If multiple tasks throw exceptions, there
is no guarantee about which of the exceptions is rethrown by this method.invokeAllAndCheckForExceptions
in interface ExecutorServices
factory
- factory capable of creating taskspublic void cleanup()
Service
protected abstract int getThreadPoolSize()
Copyright © 2013 Seam Framework. All Rights Reserved.