org.codehaus.griffon.runtime.tasks

Class DefaultTaskManager

java.lang.Object

org.codehaus.griffon.runtime.tasks.DefaultTaskManager

All Implemented Interfaces:

TaskManager

Direct Known Subclasses:

NonBlockingTaskManager

public class DefaultTaskManager
extends Object
implements TaskManager

Since:

20.07.11 18:36

Author:

Eike Kettner

Constructor Summary

Constructors

Constructor and Description
DefaultTaskManager(GriffonApplication application, ExecutorServiceManager executorServiceManager, TaskBlocker blocker)

Method Summary

Modifier and Type	Method and Description
<V,C> TaskControl<V>	create(Task<V,C> task) Creates a new TaskControl for a given task.
protected ThreadPoolExecutor	createExecutorService()
protected <V,C> TaskContext	createTaskContext(Task<V,C> task)
protected <V> TaskControl<V>	createTaskControl(TaskContext context)
protected TaskListenerSupport	createTaskListenerSupport()
TaskControl	findTask(TaskPredicate predicate)
TaskControl	getTask(String contextId) Looks up a task by the specified context id.
TaskListenerSupport	getTaskListenerSupport() Allows to add listeners.
Iterable<TaskControl>	getTasks(TaskPredicate predicate) Returns a collection of all currently created task conforming to the specified predicate.
<T> Future<T>	submit(Callable<T> task) Submits a Callable object for execution.
Future<?>	submit(Runnable task) Submits a Runnable object for execution.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultTaskManager

public DefaultTaskManager(@Nonnull
                          GriffonApplication application,
                          @Nonnull
                          ExecutorServiceManager executorServiceManager,
                          TaskBlocker blocker)

Method Detail

createTaskListenerSupport

protected TaskListenerSupport createTaskListenerSupport()

createExecutorService

protected ThreadPoolExecutor createExecutorService()

create

public <V,C> TaskControl<V> create(Task<V,C> task)

Description copied from interface: TaskManager

Creates a new TaskControl for a given task. The state is set to Task.State.PENDING and the task is not started. That allows to add listeners for this task execution before starting it.

Tasks created by this method will fire TaskEvents as appropriate. See TaskListener for details.

Specified by:

create in interface TaskManager

Returns:

createTaskControl

protected <V> TaskControl<V> createTaskControl(TaskContext context)

createTaskContext

protected <V,C> TaskContext createTaskContext(Task<V,C> task)

getTaskListenerSupport

public TaskListenerSupport getTaskListenerSupport()

Description copied from interface: TaskManager

Allows to add listeners.

Specified by:

getTaskListenerSupport in interface TaskManager

Returns:

getTasks

public Iterable<TaskControl> getTasks(TaskPredicate predicate)

Description copied from interface: TaskManager

Returns a collection of all currently created task conforming to the specified predicate. The contract is to have all started and pending tasks available. It's not necessary returning finished tasks.

Specified by:

getTasks in interface TaskManager

Returns:

findTask

public TaskControl findTask(TaskPredicate predicate)

Specified by:

findTask in interface TaskManager

submit

public Future<?> submit(Runnable task)

Description copied from interface: TaskManager

Submits a Runnable object for execution. Contrary to executing Tasks this is more lightweight as it does not fire any events and is not managed by this manager.

Specified by:

submit in interface TaskManager

Returns:

submit

public <T> Future<T> submit(Callable<T> task)

Description copied from interface: TaskManager

Submits a Callable object for execution. Contrary to executing Tasks this is more lightweight as it does not fire any events and is not managed by this manager.

Specified by:

submit in interface TaskManager

Returns:

getTask

public TaskControl getTask(String contextId)

Description copied from interface: TaskManager

Looks up a task by the specified context id.

Specified by:

getTask in interface TaskManager

Returns: