net.eduvax.util

Class Hub<T>

java.lang.Object

net.eduvax.util.Hub<T>

All Implemented Interfaces:

java.lang.Runnable, Handler<T>

public class Hub<T>
extends java.lang.Object
implements java.lang.Runnable, Handler<T>

A hub is a connector to a fifo queue that serves severals registered handlers.

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.LinkedBlockingQueue<T>	_fifo Event queue, as far as T type is an event.
private HandlerList<T>	_handlers HandlerList containing hub member handlers
private java.lang.String	_name hub name
private T	_stopObject object to insert to order Hub shutdown

Constructor Summary

Constructors

Constructor and Description
Hub(java.lang.String name) create new hub

Method Summary

Methods

Modifier and Type	Method and Description
void	add(Handler<T> handler) register handler
void	handle(T obj) Handling object by hub is enqueuing it.
void	remove(Handler<T> handler) deregister handler
void	run()
void	setStopObject(T stop) Defines obj to use as stop signal when found in queue.
void	start() Start hub with its own thread
void	stop() Request Hub shutdown.

Methods inherited from class java.lang.Object

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

Field Detail

_handlers

private HandlerList<T> _handlers

HandlerList containing hub member handlers

_fifo

private java.util.concurrent.LinkedBlockingQueue<T> _fifo

Event queue, as far as T type is an event. So may be an "anything to handle" queue.

_name

private java.lang.String _name

hub name

_stopObject

private T _stopObject

object to insert to order Hub shutdown

Constructor Detail

Hub

public Hub(java.lang.String name)

create new hub

Parameters:

name - hub name

Method Detail

start

public void start()

Start hub with its own thread

handle

public void handle(T obj)

Handling object by hub is enqueuing it.

Specified by:

handle in interface Handler<T>

Parameters:

obj - object to enqueue

setStopObject

public void setStopObject(T stop)

Defines obj to use as stop signal when found in queue. Stop object is transmited to all register handlers. All object remaining in queue are ignored unless the hub is restarted.

add

public void add(Handler<T> handler)

register handler

Parameters:

handler - handler to register to this hub

remove

public void remove(Handler<T> handler)

deregister handler

Parameters:

handler - handler to remove from this hub

stop

public void stop()

Request Hub shutdown. Shutdown may occure lately. Methods returns immediately, but stop really occurs when all object already inserted are handled.

run

public void run()

Specified by:

run in interface java.lang.Runnable