Package org.jppf.server.node

Class AsyncNodeExecutionManager

java.lang.Object
org.jppf.execute.async.AbstractAsyncExecutionManager
org.jppf.server.node.AsyncNodeExecutionManager
All Implemented Interfaces:
org.jppf.execute.async.AsyncExecutionManager
public class AsyncNodeExecutionManager extends org.jppf.execute.async.AbstractAsyncExecutionManager
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.async.AbstractAsyncExecutionManager

    configChanged, jobBundleIds, jobEntries, listeners, pendingBundleIds, pendingEntries, reconnectionNotification, taskNotificationDispatcher, threadManager, timeoutHandler

  • Constructor Summary

    Constructors
    Constructor
    Description
    AsyncNodeExecutionManager(NodeInternal node)
    Initialize this execution manager with the specified node.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    cleanup(org.jppf.execute.async.JobProcessingEntry jobEntry)
     
    protected org.jppf.execute.async.JobProcessingEntry
    setup(org.jppf.node.protocol.BundleWithTasks bundleWithTasks)
     
    void
    triggerConfigChanged()
     

    Methods inherited from class org.jppf.execute.async.AbstractAsyncExecutionManager

    addExecutionManagerListener, addPendingJobEntry, cancelAllTasks, cancelJob, checkConfigChanged, execute, fireJobFinished, getExecutor, getNbBundles, getTaskNotificationDispatcher, getThreadManager, getThreadPoolSize, getThreadsPriority, removeExecutionManagerListener, setThreadPoolSize, shutdown, taskEnded, updateThreadsPriority

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • AsyncNodeExecutionManager

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

  • Method Details

    • setup

      protected org.jppf.execute.async.JobProcessingEntry setup(org.jppf.node.protocol.BundleWithTasks bundleWithTasks)
      Specified by:
      setup in class org.jppf.execute.async.AbstractAsyncExecutionManager

    • cleanup

      protected void cleanup(org.jppf.execute.async.JobProcessingEntry jobEntry)
      Specified by:
      cleanup in class org.jppf.execute.async.AbstractAsyncExecutionManager

    • triggerConfigChanged

      public void triggerConfigChanged()
      Specified by:
      triggerConfigChanged in interface org.jppf.execute.async.AsyncExecutionManager
      Overrides:
      triggerConfigChanged in class org.jppf.execute.async.AbstractAsyncExecutionManager