public class ProfilingExecutorServices extends Object implements ExecutorServices
ExecutorServices.TaskFactory<T>
Constructor and Description |
---|
ProfilingExecutorServices(ExecutorServices delegate) |
Modifier and Type | Method and Description |
---|---|
void |
cleanup()
Called by Weld when it is shutting down, allowing the service to perform any cleanup needed.
|
ExecutorServices |
getDelegate() |
ExecutorService |
getTaskExecutor() |
<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. |
public ProfilingExecutorServices(ExecutorServices delegate)
public ExecutorService getTaskExecutor()
getTaskExecutor
in interface ExecutorServices
public void cleanup()
Service
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 ExecutorServices getDelegate()
Copyright © 2013 Seam Framework. All Rights Reserved.