Package org.jppf.load.balancer.impl

Class RL2Bundler

java.lang.Object

org.jppf.load.balancer.AbstractBundler<T>

org.jppf.load.balancer.AbstractAdaptiveBundler<RL2Profile>

org.jppf.load.balancer.impl.RL2Bundler

All Implemented Interfaces:

Bundler<RL2Profile>, BundlerEx<RL2Profile>, ChannelAwareness, ContextAwareness, JobAwareness, PersistentState

public class RL2Bundler
extends AbstractAdaptiveBundler<RL2Profile>
implements PersistentState

Bundler based on a reinforcement learning algorithm.

Author:

Laurent Cohen

Field Summary

Fields inherited from class org.jppf.load.balancer.AbstractAdaptiveBundler

bundleSize, channelConfiguration, job, nbThreads

Fields inherited from class org.jppf.load.balancer.AbstractBundler

bundlerNumber, profile, timestamp

Fields inherited from interface org.jppf.load.balancer.Bundler

BUNDLER_COUNT

Constructor Summary

Constructors

Constructor	Description
RL2Bundler(RL2Profile profile)	Creates a new instance with the specified parameters.

Method Summary

Modifier and Type	Method	Description
void	dispose()	Release the resources used by this bundler.
void	feedback(int size, double totalTime)	This implementation does nothing and should be overridden in subclasses that compute the bundle size based on the feedback from the nodes.
int	getBundleSize()	Get the current bundle size.
Object	getState()	Get this bundler's state.
Lock	getStateLock()	Get a lock that can be used to synchronize access to the load-balancer state.
void	setJob(JPPFDistributedJob job)	Set the current job for which load-balancing is being performed.
void	setState(Object persistedState)	Set this bundler's state.
void	setup()	Perform context-independent initializations.

Methods inherited from class org.jppf.load.balancer.AbstractAdaptiveBundler

feedback, getChannelConfiguration, getJob, maxSize, setChannelConfiguration

Methods inherited from class org.jppf.load.balancer.AbstractBundler

getBundlerNumber, getJPPFContext, getProfile, getTimestamp, setJPPFContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jppf.load.balancer.Bundler

getProfile, getTimestamp

Constructor Details

RL2Bundler

public RL2Bundler(RL2Profile profile)

Creates a new instance with the specified parameters.

Parameters:

profile - the parameters of the algorithm, grouped as a performance analysis profile.

Method Details

getBundleSize

public int getBundleSize()

Description copied from interface: Bundler

Get the current bundle size.

Specified by:

getBundleSize in interface Bundler<RL2Profile>

Overrides:

getBundleSize in class AbstractAdaptiveBundler<RL2Profile>

Returns:

the bundle size as an int value.

feedback

public void feedback(int size,
 double totalTime)

Description copied from class: AbstractBundler

This implementation does nothing and should be overridden in subclasses that compute the bundle size based on the feedback from the nodes.

Specified by:

feedback in interface Bundler<RL2Profile>

Overrides:

feedback in class AbstractBundler<RL2Profile>

Parameters:

size - the number of tasks retruning from execution on a node.

totalTime - the total round-trip time of the tasks, from the server to the node and back.

setJob

public void setJob(JPPFDistributedJob job)

Description copied from interface: JobAwareness

Set the current job for which load-balancing is being performed. This method should never be called directly, as it is set automatically be the JPPF load balancing framework.

Specified by:

setJob in interface JobAwareness

Overrides:

setJob in class AbstractAdaptiveBundler<RL2Profile>

Parameters:

job - a JPPFDistributedJob instance.

setup

public void setup()

Description copied from class: AbstractBundler

Perform context-independent initializations.

Specified by:

setup in interface Bundler<RL2Profile>

Overrides:

setup in class AbstractBundler<RL2Profile>

dispose

public void dispose()

Description copied from class: AbstractBundler

Release the resources used by this bundler.

Specified by:

dispose in interface Bundler<RL2Profile>

Overrides:

dispose in class AbstractAdaptiveBundler<RL2Profile>

getState

public Object getState()

Description copied from interface: PersistentState

Get this bundler's state.

Specified by:

getState in interface PersistentState

Returns:

an Object representing the state of the load-balancer.

setState

public void setState(Object persistedState)

Description copied from interface: PersistentState

Set this bundler's state.

Specified by:

setState in interface PersistentState

Parameters:

persistedState - an Object representing the state of the load-balancer.

getStateLock

public Lock getStateLock()

Description copied from interface: PersistentState

Get a lock that can be used to synchronize access to the load-balancer state. The main usage is to avoid race conditions when the state is serialized by the persistence thread, while it is being updated, in particular via its feedback() method, in another thread.

Specified by:

getStateLock in interface PersistentState

Returns:

a Lock object.