er.extensions.concurrency
Class ERXAsyncQueue<T>

java.lang.Object
  java.lang.Thread
      er.extensions.concurrency.ERXAsyncQueue<T>

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

ERS3AttachmentProcessor.ERS3UploadQueue, InstantMessengerConnection.InstantMessageQueue

public abstract class ERXAsyncQueue<T>
extends java.lang.Thread

Simple queue class that runs in a thread, waits and pulls jobs from a queue. To use it, implement the process(Object) method in your subclass.

Author:

ak

Nested Class Summary

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

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

ERXAsyncQueue()

ERXAsyncQueue(java.lang.String name)

Method Summary

void	enqueue(T o)
abstract void	process(T object)
void	run()

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, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

ERXAsyncQueue

public ERXAsyncQueue()

ERXAsyncQueue

public ERXAsyncQueue(java.lang.String name)

Method Detail

enqueue

public void enqueue(T o)

run

public final void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

process

public abstract void process(T object)