org.shared.event

Class EventProcessor<T extends Event<T,E,S>,E extends Enum<E>,S extends Enum<S>>

java.lang.Object

java.lang.Thread

org.shared.event.EventProcessor<T,E,S>

Type Parameters:

T - the Event type.

E - the Event enumeration type.

S - the Source enumeration type.

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable, EnumType<S>, Handler<T>, Source<T,S>, SourceLocal<T>, SourceRemote<T>

public abstract class EventProcessor<T extends Event<T,E,S>,E extends Enum<E>,S extends Enum<S>>
extends Thread
implements Source<T,S>, Handler<T>, Closeable

A thread going through the event processing motions BlockingQueue.take() (fetch), Event.getSource() (see who it's from), Source.getHandler() (see how the source wishes to process events), and Handler.handle(Object) (process the event).

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
EventProcessor(String name) Default constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	checkCurrentThread() Checks that Thread.currentThread() is indeed this thread.
void	close() Stops this thread.
protected void	doCatch(Throwable t) Runs the exception handler, should anything go awry in the processing loop.
protected void	doFinally() Runs the finalizer, which executes on termination of the processing loop and possibly exception handler.
Handler<T>	getHandler() Gets the Handler that will process incoming Events.
void	onLocal(T evt) Delivers an Event to the local manifestation.
void	onRemote(T evt) Delivers an Event to the remote manifestation.
void	run() Runs the event processing loop.
void	setHandler(Handler<T> handler) Sets the Handler that will process incoming Events.
String	toString() Creates a human-readable representation of this thread.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.shared.event.EnumType

getType

Methods inherited from interface org.shared.event.Handler

handle

Constructor Detail

EventProcessor

public EventProcessor(String name)

Default constructor.

Method Detail

onLocal

public void onLocal(T evt)

Description copied from interface: SourceLocal

Delivers an Event to the local manifestation.

Specified by:

onLocal in interface SourceLocal<T extends Event<T,E,S>>

close

public void close()

Stops this thread.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Source<T extends Event<T,E,S>,S extends Enum<S>>

toString

public String toString()

Creates a human-readable representation of this thread.

Overrides:

toString in class Thread

checkCurrentThread

public void checkCurrentThread()

Checks that Thread.currentThread() is indeed this thread. Helpful for enforcing a serial event processing model.

run

public void run()

Runs the event processing loop.

Specified by:

run in interface Runnable

Overrides:

run in class Thread

doCatch

protected void doCatch(Throwable t)

Runs the exception handler, should anything go awry in the processing loop. Rethrows the given exception by default.

doFinally

protected void doFinally()

Runs the finalizer, which executes on termination of the processing loop and possibly exception handler. Does nothing by default.

getHandler

public Handler<T> getHandler()

Description copied from interface: Source

Gets the Handler that will process incoming Events.

Specified by:

getHandler in interface Source<T extends Event<T,E,S>,S extends Enum<S>>

onRemote

public void onRemote(T evt)

Description copied from interface: SourceRemote

Delivers an Event to the remote manifestation.

Specified by:

onRemote in interface SourceRemote<T extends Event<T,E,S>>

setHandler

public void setHandler(Handler<T> handler)

Description copied from interface: Source

Sets the Handler that will process incoming Events.

Specified by:

setHandler in interface Source<T extends Event<T,E,S>,S extends Enum<S>>