beehive.workpool

Class LoadDistributorWithAggregation

java.lang.Object

beehive.workpool.LoadDistributorWithAggregation

public class LoadDistributorWithAggregation
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	buddySelectionPolicy
static int	dispatchThreadSleepTime
java.lang.Boolean	distributorInitialized
static java.lang.String	POLICY_MAX_QUEUE
static java.lang.String	POLICY_MIN_QUEUE
static java.lang.String	POLICY_RANDOM
static java.lang.String	POLICY_ROUND_ROBIN
static int	queueDispatchSize
static int	queueDispatchTimeout
static float	ratioOfLocalTask

Constructor Summary

Constructors

Constructor and Description
LoadDistributorWithAggregation(LocalWorkpoolImpl wpoolHandle) Constructor function

Method Summary

Modifier and Type	Method and Description
int	addTaskToHostQueue(java.lang.String location, Task t)
void	distributeTasks(java.util.Vector<Task> tasksCreated) Distribute the task in the queue based on affinity, then divide among self and chosen buddy
long	getPendingTaskCount() return the count of the pending task in the queue

Methods inherited from class java.lang.Object

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

Field Detail

distributorInitialized

public java.lang.Boolean distributorInitialized

queueDispatchTimeout

public static int queueDispatchTimeout

queueDispatchSize

public static int queueDispatchSize

ratioOfLocalTask

public static float ratioOfLocalTask

POLICY_RANDOM

public static final java.lang.String POLICY_RANDOM

See Also:

Constant Field Values

POLICY_ROUND_ROBIN

public static final java.lang.String POLICY_ROUND_ROBIN

See Also:

Constant Field Values

POLICY_MIN_QUEUE

public static final java.lang.String POLICY_MIN_QUEUE

See Also:

Constant Field Values

POLICY_MAX_QUEUE

public static final java.lang.String POLICY_MAX_QUEUE

See Also:

Constant Field Values

dispatchThreadSleepTime

public static final int dispatchThreadSleepTime

See Also:

Constant Field Values

buddySelectionPolicy

public static java.lang.String buddySelectionPolicy

Constructor Detail

LoadDistributorWithAggregation

public LoadDistributorWithAggregation(LocalWorkpoolImpl wpoolHandle)

Constructor function

Parameters:

wpoolHandle -

Method Detail

getPendingTaskCount

public long getPendingTaskCount()

return the count of the pending task in the queue

Returns:

addTaskToHostQueue

public int addTaskToHostQueue(java.lang.String location,
                              Task t)
                       throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

distributeTasks

public void distributeTasks(java.util.Vector<Task> tasksCreated)
                     throws java.rmi.RemoteException

Distribute the task in the queue based on affinity, then divide among self and chosen buddy

Parameters:

tasksCreated -

Throws:

java.rmi.RemoteException