Package org.jppf.client.balancer

Class ClientExecutionManager

java.lang.Object
org.jppf.execute.AbstractExecutionManager
org.jppf.client.balancer.ClientExecutionManager
All Implemented Interfaces:
org.jppf.execute.ExecutionManager
public class ClientExecutionManager extends org.jppf.execute.AbstractExecutionManager
Instances of this class manage the execution of JPPF tasks by a node.
Author:
Laurent Cohen, Martin JANDA, Paul Woodward

  • Field Summary

    Fields inherited from class org.jppf.execute.AbstractExecutionManager

    accumulatedElapsed, bundle, configChanged, dataProvider, jobCancelled, reconnectionNotification, taskList, taskNotificationDispatcher, taskWrapperList, threadManager, timeoutHandler, usedClassLoader, uuidList

  • Constructor Summary

    Constructors
    Constructor
    Description
    ClientExecutionManager(org.jppf.utils.TypedProperties config, org.jppf.utils.configuration.JPPFProperty<Integer> nbThreadsProperty)
    Initialize this execution manager.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    cleanup()
    Cleanup method invoked when all tasks for the current bundle have completed.
    protected void
    setup(org.jppf.node.protocol.TaskBundle bundle, List<org.jppf.node.protocol.Task<?>> taskList)
    Prepare this execution manager for executing the tasks of a bundle.

    Methods inherited from class org.jppf.execute.AbstractExecutionManager

    cancelAllTasks, checkConfigChanged, execute, getBundle, getCurrentJobId, getCurrentJobName, getExecutor, getTaskNotificationDispatcher, getThreadManager, getThreadPoolSize, getThreadsPriority, isJobCancelled, setBundle, setJobCancelled, setThreadPoolSize, shutdown, taskEnded, triggerConfigChanged, updateThreadsPriority

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • ClientExecutionManager

      public ClientExecutionManager(org.jppf.utils.TypedProperties config, org.jppf.utils.configuration.JPPFProperty<Integer> nbThreadsProperty)
      Initialize this execution manager.
      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

    • setup

      protected void setup(org.jppf.node.protocol.TaskBundle bundle, List<org.jppf.node.protocol.Task<?>> taskList)
      Prepare this execution manager for executing the tasks of a bundle.
      Specified by:
      setup in class org.jppf.execute.AbstractExecutionManager
      Parameters:
      bundle - the bundle whose tasks are to be executed.
      taskList - the list of tasks to execute.

    • cleanup

      protected void cleanup()
      Cleanup method invoked when all tasks for the current bundle have completed.
      Specified by:
      cleanup in class org.jppf.execute.AbstractExecutionManager