Package org.jppf.server.node

Class NodeExecutionManager

java.lang.Object
org.jppf.execute.AbstractExecutionManager
org.jppf.server.node.NodeExecutionManager
All Implemented Interfaces:
org.jppf.execute.ExecutionManager
public class NodeExecutionManager 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
    NodeExecutionManager(NodeInternal node)
    Initialize this execution manager with the specified node.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    cleanup()
     
    protected void
    setup(org.jppf.node.protocol.TaskBundle bundle, List<org.jppf.node.protocol.Task<?>> taskList)
     
    void
    triggerConfigChanged()
     

    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, updateThreadsPriority

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • NodeExecutionManager

      public NodeExecutionManager(NodeInternal node)
      Initialize this execution manager with the specified node.
      Parameters:
      node - the node that uses this execution manager.

  • Method Details

    • setup

      protected void setup(org.jppf.node.protocol.TaskBundle bundle, List<org.jppf.node.protocol.Task<?>> taskList)
      Specified by:
      setup in class org.jppf.execute.AbstractExecutionManager

    • cleanup

      protected void cleanup()
      Specified by:
      cleanup in class org.jppf.execute.AbstractExecutionManager

    • triggerConfigChanged

      public void triggerConfigChanged()
      Specified by:
      triggerConfigChanged in interface org.jppf.execute.ExecutionManager
      Overrides:
      triggerConfigChanged in class org.jppf.execute.AbstractExecutionManager