net.sf.jour.rt.agent
Class AsyncEventWriter.Dispatcher

java.lang.Object
  java.lang.Thread
      net.sf.jour.rt.agent.AsyncEventWriter.Dispatcher

All Implemented Interfaces:

java.lang.Runnable, ShutdownListener

Enclosing class:

AsyncEventWriter

class AsyncEventWriter.Dispatcher

extends java.lang.Thread

implements ShutdownListener

Field Summary

(package private) boolean	interrupted
(package private) java.util.Hashtable	threadQueueCount
(package private) java.util.Hashtable	toClose
(package private) java.util.Hashtable	writers

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

(package private)

AsyncEventWriter.Dispatcher(java.lang.String name)

Method Summary

(package private) void	attach(java.lang.Thread key)
(package private) void	close()
(package private) void	close(java.lang.Thread key) Close the Queue for this thread.
(package private) void	closeWriters()
(package private) BulkEventLogger	getReciver(java.lang.Thread key)
int	queueCount(java.lang.Thread key, int inc)
(package private) void	recive(java.lang.Thread key, Queue eventQueue)
void	run()
void	shutdown()
(package private) int	size()
(package private) void	write(java.lang.Thread key, Queue eventQueue)

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

interrupted

boolean interrupted

writers

java.util.Hashtable writers

threadQueueCount

java.util.Hashtable threadQueueCount

toClose

java.util.Hashtable toClose

Constructor Detail

AsyncEventWriter.Dispatcher

AsyncEventWriter.Dispatcher(java.lang.String name)

Method Detail

attach

void attach(java.lang.Thread key)

size

int size()

recive

void recive(java.lang.Thread key,
            Queue eventQueue)

close

void close()

close

void close(java.lang.Thread key)

Close the Queue for this thread.

closeWriters

void closeWriters()

write

void write(java.lang.Thread key,
           Queue eventQueue)

getReciver

BulkEventLogger getReciver(java.lang.Thread key)

queueCount

public int queueCount(java.lang.Thread key,
                      int inc)

shutdown

public void shutdown()

Specified by:

shutdown in interface ShutdownListener

run

public void run()

Specified by:

run in interface java.lang.Runnable