Uses of Interface
org.jppf.load.balancer.Bundler
Packages that use Bundler
Package
Description
Interfaces for the new load-balancing execution on the client and server side.
Classes supporting the load-balancing of tasks distribution to the servers and nodes.
This package contains the implementations of all the JPPF built-in load-balancing algorithms.
Classes supporting the persistence of the state of a load-balancer.
Support for pluggable load-balancing algorithms.
-
Uses of Bundler in org.jppf.execute
Methods in org.jppf.execute that return BundlerModifier and TypeMethodDescriptionBundler<?>ExecutorChannel.checkBundler(JPPFBundlerFactory bundlerFactory, JPPFContext jppfContext) Check whether the bundler held by this context is up to date by comparison with the specified bundler.
If it is not, then it is replaced with a copy of the specified bundler, with a timestamp taken at creation time.Bundler<?>ExecutorChannel.getBundler()Get the bundler used to schedule tasks for the corresponding node. -
Uses of Bundler in org.jppf.load.balancer
Subinterfaces of Bundler in org.jppf.load.balancerModifier and TypeInterfaceDescriptioninterfaceBundlerEx<T extends LoadBalancingProfile>A bundler which provides a more advanced feedback method with additional performance data.Classes in org.jppf.load.balancer that implement BundlerModifier and TypeClassDescriptionclassAbstractAdaptiveBundler<T extends LoadBalancingProfile>classAbstractBundler<T extends LoadBalancingProfile>Abstract implementation of theBundlerinterface.Methods in org.jppf.load.balancer with parameters of type BundlerModifier and TypeMethodDescriptionstatic voidBundlerHelper.updateBundler(Bundler<?> bundler, int nbTasks, double totalTime) Provide feedback to a bundler from a channel after execution of a set of tasks. -
Uses of Bundler in org.jppf.load.balancer.impl
Classes in org.jppf.load.balancer.impl that implement BundlerModifier and TypeClassDescriptionclassThis class implements a self tuned bundle size algorithm.classInstances of this bundler delegate their operations to a singleton instance of aAutoTunedBundler.classThis class provide a used defined bundle size jppf.load.balancing.profile.classThis implementation of a load-balancing algorithm illustrates the use of theChannelAwarenessAPIs, by sending to each node at mostm * ntasks, where n is the number of processing threads in the node, and m is a user-defined parameter which defaults to one.classThis bundler implementation computes bundle sizes proportional to the mean execution time for each node to the power of n, where n is an integer value specified in the configuration file as "proportionality factor".
The scope of this bundler is all nodes, which means that it computes the size for all nodes.
The mean execution time is computed as a moving average over a number of tasks, specified in the bundling algorithm profile configuration as "minSamplesToAnalyse"
This algorithm is well suited for relatively small networks (a few dozen nodes at most).classBundler based on a reinforcement learning algorithm. -
Uses of Bundler in org.jppf.load.balancer.persistence
Methods in org.jppf.load.balancer.persistence that return types with arguments of type BundlerModifier and TypeMethodDescriptionLoadBalancerPersistenceManager.loadBundler(Pair<String, String> channelId) Load the bundler state for the specified node, with the currently configured algorithm.Methods in org.jppf.load.balancer.persistence with parameters of type Bundler -
Uses of Bundler in org.jppf.load.balancer.spi
Methods in org.jppf.load.balancer.spi that return BundlerModifier and TypeMethodDescriptionAutoTunedBundlerProvider.createBundler(AnnealingTuneProfile profile) Create a bundler instance using the specified parameters profile.FixedSizeBundlerProvider.createBundler(FixedSizeProfile profile) Create a bundler instance using the specified parameters profile.JPPFBundlerProvider.createBundler(T profile) Create a bundler instance using the specified parameters profile.NodeThreadsBundlerProvider.createBundler(NodeThreadsProfile profile) Create a bundler instance using the specified parameters profile.ProportionalBundlerProvider.createBundler(ProportionalProfile profile) Create a bundler instance using the specified parameters profile.RL2BundlerProvider.createBundler(RL2Profile profile) Create a bundler instance using the specified parameters profile.Bundler<?>JPPFBundlerFactory.getFallbackBundler()Get the fallback bundler.Bundler<?>JPPFBundlerFactory.newBundler()Create an instance of the bundler with the specified name and parameters.