Package org.jppf.execute.async

Class AbstractAsyncExecutionManager

java.lang.Object

org.jppf.execute.async.AbstractAsyncExecutionManager

All Implemented Interfaces:

AsyncExecutionManager

public abstract class AbstractAsyncExecutionManager
extends Object
implements AsyncExecutionManager

Instances of this class manage the execution of JPPF tasks by a node.

Author:

Laurent Cohen, Martin JANDA, Paul Woodward

Field Summary

Fields

Modifier and Type	Field	Description
protected final AtomicBoolean	configChanged	Determines whether the number of threads or their priority has changed.
protected final CollectionMap<String,Long>	jobBundleIds	Mapping of job uuids to the ids of the bundles currently processed for this job.
protected final Map<String,JobProcessingEntry>	jobEntries	Mapping of jobUuid + bunldeId to the corresponding JobProcessingEntry objects.
protected final List<ExecutionManagerListener>	listeners	List of listeners to this execution manager.
protected final CollectionMap<String,Long>	pendingBundleIds	Mapping of job uuids to the ids of the pending bundles for each job.
protected final Map<String,JobPendingEntry>	pendingEntries	Map of the bundles being read from the server and not yet submitted to this execution manager.
protected AtomicReference<JPPFReconnectionNotification>	reconnectionNotification	Set if the node must reconnect to the driver.
protected final TaskExecutionDispatcher	taskNotificationDispatcher	Dispatches tasks notifications to registered listeners.
protected final ThreadManager	threadManager	The thread manager that is used for execution.
protected final JPPFScheduleHandler	timeoutHandler	Timer managing the tasks timeout.

Constructor Summary

Constructors

Constructor	Description
AbstractAsyncExecutionManager(TypedProperties config, JPPFProperty<Integer> nbThreadsProperty)	Initialize this execution manager with the specified node.

Method Summary

Modifier and Type	Method	Description
void	addExecutionManagerListener(ExecutionManagerListener listener)	Register a listener with this execution manager.
void	addPendingJobEntry(TaskBundle bundle)	Called when a task bundle s being received by the node, and before it is submitted to this execution manager.
void	cancelAllTasks(boolean callOnCancel, boolean requeue)	Cancel all executing or pending tasks.
void	cancelJob(String jobUuid, boolean callOnCancel, boolean requeue)	Cancel all executing or pending tasks for the specified job.
boolean	checkConfigChanged()	Determines whether the configuration has changed and resets the flag if it has.
protected abstract void	cleanup(JobProcessingEntry jobEntry)	Cleanup method invoked when all tasks for the current bundle have completed.
void	execute(BundleWithTasks bundleWithTasks)	Execute the specified tasks of the specified tasks bundle.
protected void	fireJobFinished(TaskBundle bundle, List<Task<?>> tasks, Throwable t)	Called when the execution of a task bundle has finished.
ExecutorService	getExecutor()	Get the executor used by this execution manager.
int	getNbBundles(String jobUuid)	Get the number of bundles with the specified job uuid that are pending or being processed.
TaskExecutionDispatcher	getTaskNotificationDispatcher()	Get the object which dispatches tasks notifications to registered listeners.
ThreadManager	getThreadManager()	Get the thread manager for this node.
int	getThreadPoolSize()	Get the size of the node's thread pool.
int	getThreadsPriority()	Get the priority assigned to the execution threads.
void	removeExecutionManagerListener(ExecutionManagerListener listener)	Remove a listener from the registered listeners.
void	setThreadPoolSize(int size)	Set the size of the node's thread pool.
protected abstract JobProcessingEntry	setup(BundleWithTasks bundleWithTasks)	Prepare this execution manager for executing the tasks of a bundle.
void	shutdown()	Shutdown this execution manager.
void	taskEnded(NodeTaskWrapper taskWrapper)	Notification that a task has finished executing.
void	triggerConfigChanged()	Trigger the configuration changed flag.
void	updateThreadsPriority(int newPriority)	Update the priority of all execution threads.

Methods inherited from class java.lang.Object

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

Field Details

timeoutHandler

protected final JPPFScheduleHandler timeoutHandler

Timer managing the tasks timeout.

taskNotificationDispatcher

protected final TaskExecutionDispatcher taskNotificationDispatcher

Dispatches tasks notifications to registered listeners.

configChanged

protected final AtomicBoolean configChanged

Determines whether the number of threads or their priority has changed.

reconnectionNotification

protected AtomicReference<JPPFReconnectionNotification> reconnectionNotification

Set if the node must reconnect to the driver.

threadManager

protected final ThreadManager threadManager

The thread manager that is used for execution.

jobEntries

protected final Map<String,JobProcessingEntry> jobEntries

Mapping of jobUuid + bunldeId to the corresponding JobProcessingEntry objects.

jobBundleIds

protected final CollectionMap<String,Long> jobBundleIds

Mapping of job uuids to the ids of the bundles currently processed for this job.

listeners

protected final List<ExecutionManagerListener> listeners

List of listeners to this execution manager.

pendingEntries

protected final Map<String,JobPendingEntry> pendingEntries

Map of the bundles being read from the server and not yet submitted to this execution manager.

pendingBundleIds

protected final CollectionMap<String,Long> pendingBundleIds

Mapping of job uuids to the ids of the pending bundles for each job.

Constructor Details

AbstractAsyncExecutionManager

public AbstractAsyncExecutionManager(TypedProperties config,
 JPPFProperty<Integer> nbThreadsProperty)

Initialize this execution manager with the specified node.

Parameters:

config - the configuration to get the thread manager properties from.

nbThreadsProperty - the name of the property which configures the number of threads.

Method Details

execute

public void execute(BundleWithTasks bundleWithTasks)
             throws Exception

Description copied from interface: AsyncExecutionManager

Execute the specified tasks of the specified tasks bundle.

Specified by:

execute in interface AsyncExecutionManager

Parameters:

bundleWithTasks - the bundle to execute with its associated tasks.

Throws:

Exception - if the execution failed.

cancelAllTasks

public void cancelAllTasks(boolean callOnCancel,
 boolean requeue)

Description copied from interface: AsyncExecutionManager

Cancel all executing or pending tasks.

Specified by:

cancelAllTasks in interface AsyncExecutionManager

Parameters:

callOnCancel - determines whether the onCancel() callback method of each task should be invoked.

requeue - true if the job should be requeued on the server side, false otherwise.

cancelJob

public void cancelJob(String jobUuid,
 boolean callOnCancel,
 boolean requeue)

Description copied from interface: AsyncExecutionManager

Cancel all executing or pending tasks for the specified job.

Specified by:

cancelJob in interface AsyncExecutionManager

Parameters:

jobUuid - the uuid of the job to cancel.

callOnCancel - determines whether the onCancel() callback method of each task should be invoked.

requeue - true if the job should be requeued on the server side, false otherwise.

shutdown

public void shutdown()

Description copied from interface: AsyncExecutionManager

Shutdown this execution manager.

Specified by:

shutdown in interface AsyncExecutionManager

setup

protected abstract JobProcessingEntry setup(BundleWithTasks bundleWithTasks)

Prepare this execution manager for executing the tasks of a bundle.

Parameters:

bundleWithTasks - the bundle and associated tasks.

Returns:

an instance of JobProcessingEntry.

cleanup

protected abstract void cleanup(JobProcessingEntry jobEntry)

Cleanup method invoked when all tasks for the current bundle have completed.

Parameters:

jobEntry - encapsulates information about the job.

taskEnded

public void taskEnded(NodeTaskWrapper taskWrapper)

Description copied from interface: AsyncExecutionManager

Notification that a task has finished executing.

Specified by:

taskEnded in interface AsyncExecutionManager

Parameters:

taskWrapper - the task that finished its execution.

getExecutor

public ExecutorService getExecutor()

Description copied from interface: AsyncExecutionManager

Get the executor used by this execution manager.

Specified by:

getExecutor in interface AsyncExecutionManager

Returns:

an ExecutorService instance.

checkConfigChanged

public boolean checkConfigChanged()

Description copied from interface: AsyncExecutionManager

Determines whether the configuration has changed and resets the flag if it has.

Specified by:

checkConfigChanged in interface AsyncExecutionManager

Returns:

true if the config was changed, false otherwise.

triggerConfigChanged

public void triggerConfigChanged()

Description copied from interface: AsyncExecutionManager

Trigger the configuration changed flag.

Specified by:

triggerConfigChanged in interface AsyncExecutionManager

setThreadPoolSize

public void setThreadPoolSize(int size)

Description copied from interface: AsyncExecutionManager

Set the size of the node's thread pool.

Specified by:

setThreadPoolSize in interface AsyncExecutionManager

Parameters:

size - the size as an int.

getThreadPoolSize

public int getThreadPoolSize()

Description copied from interface: AsyncExecutionManager

Get the size of the node's thread pool.

Specified by:

getThreadPoolSize in interface AsyncExecutionManager

Returns:

the size as an int.

getThreadsPriority

public int getThreadsPriority()

Description copied from interface: AsyncExecutionManager

Get the priority assigned to the execution threads.

Specified by:

getThreadsPriority in interface AsyncExecutionManager

Returns:

the priority as an int value.

updateThreadsPriority

public void updateThreadsPriority(int newPriority)

Description copied from interface: AsyncExecutionManager

Update the priority of all execution threads.

Specified by:

updateThreadsPriority in interface AsyncExecutionManager

Parameters:

newPriority - the new priority to set.

getThreadManager

public ThreadManager getThreadManager()

Description copied from interface: AsyncExecutionManager

Get the thread manager for this node.

Specified by:

getThreadManager in interface AsyncExecutionManager

Returns:

a ThreadManager instance.

getTaskNotificationDispatcher

public TaskExecutionDispatcher getTaskNotificationDispatcher()

Description copied from interface: AsyncExecutionManager

Get the object which dispatches tasks notifications to registered listeners.

Specified by:

getTaskNotificationDispatcher in interface AsyncExecutionManager

Returns:

a TaskExecutionDispatcher instance.

getNbBundles

public int getNbBundles(String jobUuid)

Description copied from interface: AsyncExecutionManager

Get the number of bundles with the specified job uuid that are pending or being processed.

Specified by:

getNbBundles in interface AsyncExecutionManager

Parameters:

jobUuid - the uuid of the job for which to count the bundles.

Returns:

number of bundles.

addExecutionManagerListener

public void addExecutionManagerListener(ExecutionManagerListener listener)

Description copied from interface: AsyncExecutionManager

Register a listener with this execution manager.

Specified by:

addExecutionManagerListener in interface AsyncExecutionManager

Parameters:

listener - the listener to register.

removeExecutionManagerListener

public void removeExecutionManagerListener(ExecutionManagerListener listener)

Description copied from interface: AsyncExecutionManager

Remove a listener from the registered listeners.

Specified by:

removeExecutionManagerListener in interface AsyncExecutionManager

Parameters:

listener - the listener to remove.

fireJobFinished

protected void fireJobFinished(TaskBundle bundle,
 List<Task<?>> tasks,
 Throwable t)

Called when the execution of a task bundle has finished.

Parameters:

bundle - the TaskBundle which holds information on the job.

tasks - the tasks that were executed.

t - a Throwable that prevented or interrupted the job processing.

addPendingJobEntry

public void addPendingJobEntry(TaskBundle bundle)

Description copied from interface: AsyncExecutionManager

Called when a task bundle s being received by the node, and before it is submitted to this execution manager.

Specified by:

addPendingJobEntry in interface AsyncExecutionManager

Parameters:

bundle - the bundle to process.