Package org.jppf.load.balancer.impl
Class AutotunedDelegatingBundler
java.lang.Object
org.jppf.load.balancer.AbstractBundler<AnnealingTuneProfile>
org.jppf.load.balancer.impl.AutotunedDelegatingBundler
- All Implemented Interfaces:
Bundler<AnnealingTuneProfile>,ContextAwareness
Instances of this bundler delegate their operations to a singleton instance of a
AutoTunedBundler.- Author:
- Laurent Cohen
-
Field Summary
Fields inherited from class org.jppf.load.balancer.AbstractBundler
bundlerNumber, profile, timestampFields inherited from interface org.jppf.load.balancer.Bundler
BUNDLER_COUNT -
Constructor Summary
ConstructorsConstructorDescriptionCreates a new instance with the initial size of bundle as the start size. -
Method Summary
Methods inherited from class org.jppf.load.balancer.AbstractBundler
dispose, getBundlerNumber, getJPPFContext, getProfile, getTimestamp, setJPPFContext, setup
-
Constructor Details
-
AutotunedDelegatingBundler
Creates a new instance with the initial size of bundle as the start size.- Parameters:
profile- the parameters of the auto-tuning algorithm grouped as a performance analysis profile.
-
-
Method Details
-
getBundleSize
public int getBundleSize()Get the current size of bundle.- Returns:
- the bundle size as an int value.
-
feedback
public void feedback(int bundleSize, double totalTime) This method delegates the bundle size calculation to the singleton instance ofSimpleBundler.- Specified by:
feedbackin interfaceBundler<AnnealingTuneProfile>- Overrides:
feedbackin classAbstractBundler<AnnealingTuneProfile>- Parameters:
bundleSize- the number of tasks executed.totalTime- the time in nanoseconds it took to execute the tasks.
-
maxSize
public int maxSize()Get the max bundle size that can be used for this bundler.- Overrides:
maxSizein classAbstractBundler<AnnealingTuneProfile>- Returns:
- the bundle size as an int.
-