beehive.workpool

Class LoadDistributorV2

java.lang.Object

beehive.workpool.LoadDistributorV2

public class LoadDistributorV2
extends Object

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
LoadDistributorV2(LocalWorkpoolImpl wpoolHandle) Constructor function

Method Summary

Modifier and Type	Method and Description
void	distributeTasks(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 Boolean distributorInitialized

queueDispatchTimeout

public static int queueDispatchTimeout

queueDispatchSize

public static int queueDispatchSize

ratioOfLocalTask

public static float ratioOfLocalTask

POLICY_RANDOM

public static final String POLICY_RANDOM

See Also:

Constant Field Values

POLICY_ROUND_ROBIN

public static final String POLICY_ROUND_ROBIN

See Also:

Constant Field Values

POLICY_MIN_QUEUE

public static final String POLICY_MIN_QUEUE

See Also:

Constant Field Values

POLICY_MAX_QUEUE

public static final String POLICY_MAX_QUEUE

See Also:

Constant Field Values

dispatchThreadSleepTime

public static final int dispatchThreadSleepTime

See Also:

Constant Field Values

buddySelectionPolicy

public static String buddySelectionPolicy

Constructor Detail

LoadDistributorV2

public LoadDistributorV2(LocalWorkpoolImpl wpoolHandle)

Constructor function

Parameters:

wpoolHandle -

Method Detail

getPendingTaskCount

public long getPendingTaskCount()

return the count of the pending task in the queue

Returns:

distributeTasks

public void distributeTasks(Vector<Task> tasksCreated)
                     throws RemoteException

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

Parameters:

tasksCreated -

Throws:

RemoteException