|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.lang.Thread
com.sun.grizzly.util.WorkerThread
com.sun.grizzly.util.WorkerThreadImpl
public class WorkerThreadImpl
Simple worker thread used for processing HTTP requests. All threads are
synchronized using a Pipeline
object
Nested Class Summary |
---|
Nested classes/interfaces inherited from class java.lang.Thread |
---|
Thread.State, Thread.UncaughtExceptionHandler |
Field Summary | |
---|---|
protected boolean |
execute
Looing variable. |
protected Pipeline<Callable> |
pipeline
The Pipeline on which this thread synchronize. |
protected Runnable |
target
What will be run. |
protected static ThreadGroup |
threadGroup
The ThreadGroup used. |
Fields inherited from class com.sun.grizzly.util.WorkerThread |
---|
byteBuffer, inputBB, outputBB, sslEngine |
Fields inherited from class java.lang.Thread |
---|
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Constructor Summary | |
---|---|
WorkerThreadImpl(Pipeline<Callable> pipeline,
String name)
Create a Thread that will synchronizes/block on Pipeline instance. |
|
WorkerThreadImpl(Pipeline<Callable> pipeline,
String name,
int initialByteBufferSize)
Create a Thread that will synchronizes/block on Pipeline instance. |
|
WorkerThreadImpl(ThreadGroup threadGroup,
Runnable runnable)
Create a Thread that will synchronizes/block on Pipeline instance. |
|
WorkerThreadImpl(ThreadGroup threadGroup,
Runnable runnable,
int initialByteBufferSize)
Create a Thread that will synchronizes/block on Pipeline instance. |
Method Summary | |
---|---|
void |
attach(ThreadAttachment threadAttachment)
Attach the ThreadAttachment to this instance. |
ThreadAttachment |
detach()
Detach the current set of attributes (state) associated with this instance. |
ThreadAttachment |
getAttachment()
Get the current set of attributes (state) associated with this instance. |
ByteBufferFactory.ByteBufferType |
getByteBufferType()
The ByteBufferType used to create the ByteBuffer
associated with this object. |
protected void |
reset()
|
void |
run()
Execute a Task . |
void |
setByteBufferType(ByteBufferFactory.ByteBufferType byteBufferType)
Set the ByteBufferType to use when creating the
ByteBuffer associated with this object. |
void |
terminate()
Stop this thread. |
ThreadAttachment |
updateAttachment(int mode)
Updates Thread associated attachment according to the passed mode. |
Methods inherited from class com.sun.grizzly.util.WorkerThread |
---|
getByteBuffer, getInputBB, getOutputBB, getSSLEngine, setByteBuffer, setInputBB, setOutputBB, setSSLEngine |
Methods inherited from class java.lang.Thread |
---|
activeCount, checkAccess, 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 |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
protected Runnable target
protected Pipeline<Callable> pipeline
Pipeline
on which this thread synchronize.
protected volatile boolean execute
protected static final ThreadGroup threadGroup
ThreadGroup
used.
Constructor Detail |
---|
public WorkerThreadImpl(ThreadGroup threadGroup, Runnable runnable)
Pipeline
instance.
threadGroup
- ThreadGroup
runnable
- Runnable
public WorkerThreadImpl(ThreadGroup threadGroup, Runnable runnable, int initialByteBufferSize)
Pipeline
instance.
threadGroup
- ThreadGroup
runnable
- Runnable
initialByteBufferSize
- initial ByteBuffer
sizepublic WorkerThreadImpl(Pipeline<Callable> pipeline, String name)
Pipeline
instance.
pipeline
- Pipeline
name
- String
public WorkerThreadImpl(Pipeline<Callable> pipeline, String name, int initialByteBufferSize)
Pipeline
instance.
pipeline
- Pipeline
name
- String
initialByteBufferSize
- initial ByteBuffer
sizeMethod Detail |
---|
public void run()
Task
.
run
in interface Runnable
run
in class Thread
public void terminate()
terminate
in class WorkerThread
public ThreadAttachment updateAttachment(int mode)
WorkerThread
updateAttachment
in class WorkerThread
public ThreadAttachment getAttachment()
WorkerThread
getAttachment
in class WorkerThread
public ThreadAttachment detach()
WorkerThread
detach
in class WorkerThread
public void attach(ThreadAttachment threadAttachment)
WorkerThread
attach
in class WorkerThread
public ByteBufferFactory.ByteBufferType getByteBufferType()
ByteBufferType
used to create the ByteBuffer
associated with this object.
ByteBufferType
used to create the ByteBuffer
associated with this object.public void setByteBufferType(ByteBufferFactory.ByteBufferType byteBufferType)
ByteBufferType
to use when creating the
ByteBuffer
associated with this object.
byteBufferType
- The ByteBuffer type.protected void reset()
reset
in class WorkerThread
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |