Package org.jppf.load.balancer

Class BundlerHelper

java.lang.Object
org.jppf.load.balancer.BundlerHelper
public class BundlerHelper extends Object
Collection of static utility methods to help with bundler operations.
Author:
Laurent Cohen

  • Constructor Summary

    Constructors
    Constructor
    Description
    BundlerHelper()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static void
    updateBundler(Bundler<?> bundler, int nbTasks, double totalTime)
    Provide feedback to a bundler from a channel after execution of a set of tasks.
    static void
    updateBundler(BundlerEx<?> bundler, int nbTasks, double totalTime, double accumulatedElapsed, double overheadTime)
    Provide feedback to a bundler with the result of using the bundle with the specified size.

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • BundlerHelper

      public BundlerHelper()

  • Method Details

    • updateBundler

      public static void updateBundler(Bundler<?> bundler, int nbTasks, double totalTime)
      Provide feedback to a bundler from a channel after execution of a set of tasks. The feedback data consists in providing a number of tasks that were executed, and their total execution time in milliseconds. The execution time includes the network round trip between node and server.
      Parameters:
      bundler - the load banlancer to update.
      nbTasks - number of tasks that were executed.
      totalTime - the total execution and transport time in nanoseconds.

    • updateBundler

      public static void updateBundler(BundlerEx<?> bundler, int nbTasks, double totalTime, double accumulatedElapsed, double overheadTime)
      Provide feedback to a bundler with the result of using the bundle with the specified size. The feedback data consists in providing a number of tasks that were executed, and their total execution time in milliseconds. The execution time includes the network round trip between node and server.
      Parameters:
      bundler - the load banlancer to update.
      nbTasks - number of tasks that were executed.
      totalTime - the total execution and transport time in nanoseconds.
      accumulatedElapsed - the total accumalated elapsed time (in the node) in nanoseconds for the execution of the tasks.
      overheadTime - the transport time in nanoseconds.