org.jppf.server.scheduler.bundle

Interface Bundler

All Known Subinterfaces:

BundlerEx

All Known Implementing Classes:

AbstractAdaptiveBundler, AbstractBundler

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.

Method Summary

Methods

Modifier and Type	Method and Description
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-independent 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 in nanoseconds.

copy

Bundler copy()

Make a copy of this bundler. Which 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-independent initializations.

getProfile

LoadBalancingProfile getProfile()

Get the parameters profile used by this load-balancer.

Returns:

an instance of LoadBalancingProfile.