org.jppf.server.scheduler.bundle
Interface Bundler

All Known Implementing Classes:

AbstractAutoTunedBundler, AbstractBundler, AbstractProportionalBundler, AbstractRLBundler, AutoTunedBundler, AutotunedDelegatingBundler, ClientProportionalBundler, FixedSizeBundler, NodeSimulator.SimulatedProportionalBundler, ProportionalBundler, RLBundler

public interface Bundler

This is the interface of all strategies for defining bundle task size. A Bundler defines the current bundle size using different algorithms, depending on the implementation.

Author:

Domingos Creado, Laurent Cohen

Method Summary

Bundler	copy() Make a copy of this bundler.
void	dispose() Release the resources used by this bundler.
void	feedback(int nbTasks, double totalTime) Feedback the bundler with the result of using the bundle with the specified size.
int	getBundleSize() Get the current size of bundle.
LoadBalancingProfile	getProfile() Get the parameters profile used by this load-balancer.
long	getTimestamp() Get the timestamp at which this bundler was created.
void	setup() Perform context-independant initializations.

Method Detail

getBundleSize

int getBundleSize()

Get the current size of bundle.

Returns:

the bundle size as an int value.

feedback

void feedback(int nbTasks,
              double totalTime)

Feedback the 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:

nbTasks - number of tasks that were executed.

totalTime - the total execution and transport time.

copy

Bundler copy()

Make a copy of this bundler. Wich parts are actually copied depends on the implementation.

Returns:

a new Bundler instance.

getTimestamp

long getTimestamp()

Get the timestamp at which this bundler was created. This is used to enable node channels to know when the bundler settings have changed.

Returns:

the timestamp as a long value.

dispose

void dispose()

Release the resources used by this bundler.

setup

void setup()

Perform context-independant initializations.

getProfile

LoadBalancingProfile getProfile()

Get the parameters profile used by this load-balancer.

Returns:

an instance of LoadBalancingProfile.