com.caucho.env.thread2

Class AbstractTaskWorker2

java.lang.Object

com.caucho.env.thread2.AbstractTaskWorker2

All Implemented Interfaces:

TaskWorker, java.io.Closeable, java.lang.AutoCloseable, 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

Constructors

Modifier	Constructor and Description
protected	AbstractTaskWorker2(java.lang.ClassLoader classLoader)

Method Summary

Modifier and Type	Method and Description
void	close()
protected java.lang.ClassLoader	getClassLoader()
protected long	getCurrentTimeActual()
java.lang.String	getState()
protected java.lang.String	getThreadName()
boolean	isClosed()
protected boolean	isPermanent()
protected boolean	isRetry()
boolean	isTaskActive()
protected boolean	isWeakClose()
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

isWeakClose

protected boolean isWeakClose()

isPermanent

protected boolean isPermanent()

setWorkerIdleTimeout

protected void setWorkerIdleTimeout(long timeout)

isTaskActive

public final boolean isTaskActive()

isClosed

public boolean isClosed()

getState

public java.lang.String getState()

getClassLoader

protected java.lang.ClassLoader getClassLoader()

runTask

public abstract long runTask()

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

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()

isRetry

protected boolean isRetry()

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