edu.umass.cs.protocoltask

Class ProtocolExecutor<NodeIDType,EventType,KeyType>

java.lang.Object

edu.umass.cs.protocoltask.ProtocolExecutor<NodeIDType,EventType,KeyType>

Type Parameters:

NodeIDType -

EventType -

KeyType - The purpose of this class is to store ProtocolTasks and activate them when a corresponding event arrives.

public class ProtocolExecutor<NodeIDType,EventType,KeyType>
extends java.lang.Object

Author:

V. Arun

Field Summary

Fields

Modifier and Type	Field and Description
protected static long	DEFAULT_RESTART_PERIOD
protected static int	MAX_TASKS
protected static int	MAX_THREADS
protected static long	TOO_MANY_TASKS_CHECK_PERIOD

Constructor Summary

Constructors

Constructor and Description
ProtocolExecutor(Messenger<NodeIDType,?> messenger)

Method Summary

Modifier and Type	Method and Description
static void	cancel(ProtocolTask<?,?,?> task)
static void	enqueueCancel(java.lang.Object key)
int	getActiveCount()
long	getCompletedTaskCount()
static java.util.logging.Logger	getLogger()
ProtocolTask<NodeIDType,EventType,KeyType>	getTask(KeyType key)
long	getTaskCount()
boolean	handleEvent(ProtocolEvent<EventType,KeyType> event)
boolean	isEmpty()
boolean	isRunning(KeyType key)
static void	main(java.lang.String[] args)
void	register(EventType event, ProtocolTask<NodeIDType,EventType,KeyType> task)
void	register(ProtocolTask<NodeIDType,EventType,KeyType> task)
void	register(java.util.Set<EventType> events, ProtocolTask<NodeIDType,EventType,KeyType> task)
ProtocolTask<?,?,?>	remove(KeyType key)
void	schedule(SchedulableProtocolTask<NodeIDType,EventType,KeyType> actualTask)
void	schedule(SchedulableProtocolTask<NodeIDType,EventType,KeyType> actualTask, long period)
java.util.concurrent.Future<?>	scheduleSimple(java.lang.Runnable task, long initialDelay, java.util.concurrent.TimeUnit unit)
java.util.concurrent.Future<?>	scheduleWithFixedDelay(java.lang.Runnable task, long initialDelay, long period, java.util.concurrent.TimeUnit unit)
int	size()
void	spawn(ProtocolTask<NodeIDType,EventType,KeyType> actualTask)
boolean	spawnIfNotRunning(ProtocolTask<NodeIDType,EventType,KeyType> actualTask)
void	stop()
java.util.concurrent.Future<?>	submit(java.lang.Runnable task)
java.lang.String	toString()
void	unRegister(EventType event, ProtocolTask<NodeIDType,EventType,KeyType> task)

Methods inherited from class java.lang.Object

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

Field Detail

MAX_TASKS

protected static final int MAX_TASKS

See Also:

Constant Field Values

MAX_THREADS

protected static final int MAX_THREADS

See Also:

Constant Field Values

DEFAULT_RESTART_PERIOD

protected static final long DEFAULT_RESTART_PERIOD

See Also:

Constant Field Values

TOO_MANY_TASKS_CHECK_PERIOD

protected static final long TOO_MANY_TASKS_CHECK_PERIOD

See Also:

Constant Field Values

Constructor Detail

ProtocolExecutor

public ProtocolExecutor(Messenger<NodeIDType,?> messenger)

Parameters:

messenger -

Method Detail

getLogger

public static java.util.logging.Logger getLogger()

Returns:

Logger.

register

public void register(EventType event,
                     ProtocolTask<NodeIDType,EventType,KeyType> task)

Parameters:

event -

task -

register

public void register(java.util.Set<EventType> events,
                     ProtocolTask<NodeIDType,EventType,KeyType> task)

Parameters:

events -

task -

register

public void register(ProtocolTask<NodeIDType,EventType,KeyType> task)

Parameters:

task -

unRegister

public void unRegister(EventType event,
                       ProtocolTask<NodeIDType,EventType,KeyType> task)

Parameters:

event -

task -

spawn

public void spawn(ProtocolTask<NodeIDType,EventType,KeyType> actualTask)

Parameters:

actualTask -

spawnIfNotRunning

public boolean spawnIfNotRunning(ProtocolTask<NodeIDType,EventType,KeyType> actualTask)

Parameters:

actualTask -

Returns:

True if spawned.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

stop

public void stop()

submit

public java.util.concurrent.Future<?> submit(java.lang.Runnable task)

Parameters:

task -

Returns:

Future corresponding to scheduled task.

scheduleWithFixedDelay

public java.util.concurrent.Future<?> scheduleWithFixedDelay(java.lang.Runnable task,
                                                             long initialDelay,
                                                             long period,
                                                             java.util.concurrent.TimeUnit unit)

Parameters:

task -

initialDelay -

period -

unit -

Returns:

Future corresponding to scheduled task.

scheduleSimple

public java.util.concurrent.Future<?> scheduleSimple(java.lang.Runnable task,
                                                     long initialDelay,
                                                     java.util.concurrent.TimeUnit unit)

Parameters:

task -

initialDelay -

unit -

Returns:

Future corresponding to scheduled task.

schedule

public void schedule(SchedulableProtocolTask<NodeIDType,EventType,KeyType> actualTask,
                     long period)

Parameters:

actualTask -

period -

schedule

public void schedule(SchedulableProtocolTask<NodeIDType,EventType,KeyType> actualTask)

Parameters:

actualTask -

getTask

public ProtocolTask<NodeIDType,EventType,KeyType> getTask(KeyType key)

Parameters:

key -

Returns:

ProtocolTask if any mapped to key.

remove

public ProtocolTask<?,?,?> remove(KeyType key)

Parameters:

key -

Returns:

The removed task if any.

handleEvent

public boolean handleEvent(ProtocolEvent<EventType,KeyType> event)

Parameters:

event -

Returns:

True if handled.

isEmpty

public boolean isEmpty()

Returns:

True if no scheduled tasks.

enqueueCancel

public static void enqueueCancel(java.lang.Object key)

Parameters:

key -

isRunning

public boolean isRunning(KeyType key)

Parameters:

key -

Returns:

True if task corresponding to key is running.

cancel

public static void cancel(ProtocolTask<?,?,?> task)

Parameters:

task -

getActiveCount

public int getActiveCount()

Returns:

Number of active tasks.

getTaskCount

public long getTaskCount()

Returns:

Number of tasks in underlying Executor.

getCompletedTaskCount

public long getCompletedTaskCount()

Returns:

Completed task count in underlying Executor.

size

public int size()

Returns:

Number of scheduled tasks.

main

public static void main(java.lang.String[] args)

Parameters:

args -