|
||||||||||
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 DefaultThreadPool
object
Nested Class Summary |
---|
Nested classes/interfaces inherited from class java.lang.Thread |
---|
Thread.State, Thread.UncaughtExceptionHandler |
Field Summary | |
---|---|
protected static ThreadGroup |
threadGroup
The ThreadGroup used. |
protected DefaultThreadPool |
threadPool
The DefaultThreadPool on which this thread synchronize. |
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(DefaultThreadPool threadPool,
String name)
Create a Thread that will synchronizes/block on DefaultThreadPool instance. |
|
WorkerThreadImpl(DefaultThreadPool threadPool,
String name,
int initialByteBufferSize)
Create a Thread that will synchronizes/block on DefaultThreadPool instance. |
|
WorkerThreadImpl(DefaultThreadPool threadPool,
String name,
Runnable runnable,
int initialByteBufferSize)
Create a Thread that will synchronizes/block on DefaultThreadPool instance. |
|
WorkerThreadImpl(ThreadGroup threadGroup,
Runnable runnable)
Create a Thread that will synchronizes/block on DefaultThreadPool instance. |
|
WorkerThreadImpl(ThreadGroup threadGroup,
Runnable runnable,
int initialByteBufferSize)
Create a Thread that will synchronizes/block on DefaultThreadPool instance. |
Method Summary | |
---|---|
void |
attach(ThreadAttachment threadAttachment)
Attach the ThreadAttachment to this instance. |
protected void |
createByteBuffer(boolean force)
Allocate a ByteBuffer if the current instance is null; |
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 |
processTask(Callable t)
Processes the given task. |
protected void |
reset()
|
void |
setByteBufferType(ByteBufferFactory.ByteBufferType byteBufferType)
Set the ByteBufferType to use when creating the
ByteBuffer associated with this object. |
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, run, 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 DefaultThreadPool threadPool
DefaultThreadPool
on which this thread synchronize.
protected static final ThreadGroup threadGroup
ThreadGroup
used.
Constructor Detail |
---|
public WorkerThreadImpl(ThreadGroup threadGroup, Runnable runnable)
DefaultThreadPool
instance.
threadGroup
- ThreadGroup
runnable
- Runnable
public WorkerThreadImpl(ThreadGroup threadGroup, Runnable runnable, int initialByteBufferSize)
DefaultThreadPool
instance.
threadGroup
- ThreadGroup
runnable
- Runnable
initialByteBufferSize
- initial ByteBuffer
sizepublic WorkerThreadImpl(DefaultThreadPool threadPool, String name)
DefaultThreadPool
instance.
threadPool
- DefaultThreadPool
name
- String
public WorkerThreadImpl(DefaultThreadPool threadPool, String name, int initialByteBufferSize)
DefaultThreadPool
instance.
threadPool
- DefaultThreadPool
name
- String
initialByteBufferSize
- initial ByteBuffer
sizepublic WorkerThreadImpl(DefaultThreadPool threadPool, String name, Runnable runnable, int initialByteBufferSize)
DefaultThreadPool
instance.
threadPool
- DefaultThreadPool
name
- String
initialByteBufferSize
- initial ByteBuffer
sizeMethod Detail |
---|
protected void createByteBuffer(boolean force)
ByteBuffer
if the current instance is null;
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 processTask(Callable t) throws Exception
t
- the task to process
Exception
protected void reset()
reset
in class WorkerThread
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |