Package org.jppf.load.balancer.impl

Class NodeThreadsBundler

java.lang.Object

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

org.jppf.load.balancer.impl.NodeThreadsBundler

All Implemented Interfaces:

Bundler<NodeThreadsProfile>, ChannelAwareness, ContextAwareness

public class NodeThreadsBundler
extends AbstractBundler<NodeThreadsProfile>
implements ChannelAwareness

This implementation of a load-balancing algorithm illustrates the use of the ChannelAwareness APIs, by sending to each node at most m * n tasks, where n is the number of processing threads in the node, and m is a user-defined parameter which defaults to one.

Author:

Laurent Cohen

Field Summary

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
NodeThreadsBundler(NodeThreadsProfile profile)	Creates a new instance with the specified parameters profile.

Method Summary

Modifier and Type	Method	Description
void	dispose()	Release the resources used by this bundler.
int	getBundleSize()	Get the current number of tasks to send to the node.
JPPFSystemInformation	getChannelConfiguration()	Get the corresponding node's system information.
void	setChannelConfiguration(JPPFSystemInformation channelConfiguration)	Set the corresponding node's system information.

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

feedback, getBundlerNumber, getJPPFContext, getProfile, getTimestamp, maxSize, setJPPFContext, setup

Methods inherited from class java.lang.Object

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

Constructor Details

NodeThreadsBundler

public NodeThreadsBundler(NodeThreadsProfile profile)

Creates a new instance with the specified parameters profile.

Parameters:

profile - the parameters of the load-balancing algorithm.

Method Details

getBundleSize

public int getBundleSize()

Get the current number of tasks to send to the node.

Specified by:

getBundleSize in interface Bundler<NodeThreadsProfile>

Returns:

the bundle size as an int value.

getChannelConfiguration

public JPPFSystemInformation getChannelConfiguration()

Description copied from interface: ChannelAwareness

Get the corresponding node's system information.

Specified by:

getChannelConfiguration in interface ChannelAwareness

Returns:

a JPPFSystemInformation instance.

setChannelConfiguration

public void setChannelConfiguration(JPPFSystemInformation channelConfiguration)

Description copied from interface: ChannelAwareness

Set the corresponding node's system information.

Specified by:

setChannelConfiguration in interface ChannelAwareness

Parameters:

channelConfiguration - a JPPFSystemInformation instance.

dispose

public void dispose()

Release the resources used by this bundler.

Specified by:

dispose in interface Bundler<NodeThreadsProfile>

Overrides:

dispose in class AbstractBundler<NodeThreadsProfile>