com.devexperts.qd.qtp

Class QTPWorkerThread

java.lang.Object

java.lang.Thread

com.devexperts.qd.qtp.QTPWorkerThread

All Implemented Interfaces:

AbstractMessageConnector.Joinable, Runnable

Direct Known Subclasses:

AbstractConnectionHandler

public abstract class QTPWorkerThread
extends Thread
implements AbstractMessageConnector.Joinable

Daemon worker thread that distinguished between being gracefully closed by its parent, or being forcefully interrupted/stopped by someone else.

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected com.devexperts.logging.Logging	log

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	QTPWorkerThread(String name)

Method Summary

Modifier and Type	Method and Description
void	close() Marks thread as "closed" and interrupts it (if needed).
protected abstract void	doWork()
protected abstract void	handleClose(Throwable reason)
protected abstract void	handleShutdown()
boolean	isClosed() Returns true if thread is closed and clears interrupt flag.
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

Methods inherited from interface com.devexperts.qd.qtp.AbstractMessageConnector.Joinable

join

Field Detail

log

protected final com.devexperts.logging.Logging log

Constructor Detail

QTPWorkerThread

protected QTPWorkerThread(String name)

Method Detail

close

public final void close()

Marks thread as "closed" and interrupts it (if needed).

isClosed

public final boolean isClosed()
                       throws InterruptedException

Returns true if thread is closed and clears interrupt flag.

Returns:

true if thread is closed and clears interrupt flag

Throws:

InterruptedException - if thread is interrupted without call to close().

run

public final void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

doWork

protected abstract void doWork()
                        throws Throwable

Throws:

Throwable

handleShutdown

protected abstract void handleShutdown()

handleClose

protected abstract void handleClose(Throwable reason)