com.caucho.env.thread2
Class AbstractTaskWorker2

java.lang.Object
  extended by com.caucho.env.thread2.AbstractTaskWorker2
All Implemented Interfaces:
TaskWorker, java.io.Closeable, java.lang.Runnable
Direct Known Subclasses:
AbstractTaskWorker, AbstractThreadLauncher2

public abstract class AbstractTaskWorker2
extends java.lang.Object
implements java.lang.Runnable, TaskWorker, java.io.Closeable

A generic pool of threads available for Alarms and Work tasks.


Constructor Summary
protected AbstractTaskWorker2(java.lang.ClassLoader classLoader)
           
 
Method Summary
 void close()
           
protected  java.lang.ClassLoader getClassLoader()
           
protected  long getCurrentTimeActual()
           
protected  java.lang.String getThreadName()
           
 boolean isClosed()
           
protected  boolean isPermanent()
           
 boolean isTaskActive()
           
protected  void onThreadComplete()
           
protected  void onThreadStart()
           
 void run()
           
abstract  long runTask()
           
protected  void setWorkerIdleTimeout(long timeout)
           
protected abstract  void startWorkerThread()
           
 java.lang.String toString()
           
protected  void unpark(java.lang.Thread thread)
           
 void wake()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

AbstractTaskWorker2

protected AbstractTaskWorker2(java.lang.ClassLoader classLoader)
Method Detail

isPermanent

protected boolean isPermanent()

setWorkerIdleTimeout

protected void setWorkerIdleTimeout(long timeout)

isTaskActive

public final boolean isTaskActive()

isClosed

public boolean isClosed()

getClassLoader

protected java.lang.ClassLoader getClassLoader()

runTask

public abstract long runTask()

close

public void close()
Specified by:
close in interface java.io.Closeable

wake

public final void wake()
Specified by:
wake in interface TaskWorker

startWorkerThread

protected abstract void startWorkerThread()

unpark

protected void unpark(java.lang.Thread thread)

getThreadName

protected java.lang.String getThreadName()

onThreadStart

protected void onThreadStart()

onThreadComplete

protected void onThreadComplete()

run

public final void run()
Specified by:
run in interface java.lang.Runnable

getCurrentTimeActual

protected long getCurrentTimeActual()

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object