Package edu.duke.cs.osprey.parallelism

Class WorkQueueThread<T>

java.lang.Object

java.lang.Thread

edu.duke.cs.osprey.parallelism.WorkThread

edu.duke.cs.osprey.parallelism.WorkQueueThread<T>

All Implemented Interfaces:

edu.duke.cs.tpie.Cleaner.Cleanable, Runnable

public abstract class WorkQueueThread<T>
extends WorkThread

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
BlockingQueue<T>	queue

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
WorkQueueThread(String name, BlockingQueue<T> queue)

Method Summary

Modifier and Type	Method	Description
void	doWork()
protected abstract void	doWork(T work)

Methods inherited from class edu.duke.cs.osprey.parallelism.WorkThread

askToStop, askToStopAndWait, clean, isRunning, run

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

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

Field Details

queue

public BlockingQueue<T> queue

Constructor Details

WorkQueueThread

public WorkQueueThread(String name,
 BlockingQueue<T> queue)

Method Details

doWork

public void doWork()
            throws InterruptedException

Specified by:

doWork in class WorkThread

Throws:

InterruptedException

doWork

protected abstract void doWork(T work)
                        throws InterruptedException

Throws:

InterruptedException