er.extensions.concurrency

Class ERXAsyncQueue<T>

java.lang.Object

java.lang.Thread

er.extensions.concurrency.ERXAsyncQueue<T>

Type Parameters:

T -

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

ERAttachmentUploadQueue, InstantMessengerConnection.InstantMessageQueue

public abstract class ERXAsyncQueue<T>
extends 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

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
ERXAsyncQueue()
ERXAsyncQueue(String name)

Method Summary

Modifier and Type	Method and Description
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(String name)

Method Detail

enqueue

public void enqueue(T o)

run

public final void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

process

public abstract void process(T object)