Package org.cdlib.mrt.core

Class ThreadHandler

java.lang.Object

org.cdlib.mrt.core.ThreadHandler

public class ThreadHandler
extends Object

Run fixity

Author:

dloy

Field Summary

Fields

Modifier and Type	Field	Description
protected static boolean	debug
protected LoggerInf	logger
protected static final String	MESSAGE
protected static final String	NAME
protected long	pollTime
protected Exception	saveException
protected boolean	shutdown
protected static final boolean	STATUS
protected int	threadCnt
protected Thread[]	threads

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ThreadHandler(long pollTime, int threadCnt, LoggerInf logger)

Method Summary

Modifier and Type	Method	Description
protected void	completeThreads()
int	getActiveCnt()
int	getThreadCnt()
static ThreadHandler	getThreadHandler(long pollTime, int threadCnt, LoggerInf logger)
protected void	initialThreads()
static boolean	isDebug()
boolean	isShutdown()
ProcessStatus	runThread(Runnable processItem)
static void	setDebug(boolean debug)
void	setShutdown(boolean shutdown)
void	shutdown()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

NAME

protected static final String NAME

See Also:

• Constant Field Values

MESSAGE

protected static final String MESSAGE

See Also:

• Constant Field Values

debug

protected static boolean debug

STATUS

protected static final boolean STATUS

See Also:

• Constant Field Values

threads

protected Thread[] threads

threadCnt

protected int threadCnt

pollTime

protected long pollTime

saveException

protected Exception saveException

shutdown

protected boolean shutdown

logger

protected LoggerInf logger

Constructor Details

ThreadHandler

protected ThreadHandler(long pollTime,
 int threadCnt,
 LoggerInf logger)
                 throws TException

Throws:

TException

Method Details

getThreadHandler

public static ThreadHandler getThreadHandler(long pollTime,
 int threadCnt,
 LoggerInf logger)
                                      throws TException

Throws:

TException

shutdown

public void shutdown()
              throws TException

Throws:

TException

runThread

public ProcessStatus runThread(Runnable processItem)

completeThreads

protected void completeThreads()

getActiveCnt

public int getActiveCnt()

initialThreads

protected void initialThreads()

isShutdown

public boolean isShutdown()

setShutdown

public void setShutdown(boolean shutdown)

isDebug

public static boolean isDebug()

setDebug

public static void setDebug(boolean debug)

getThreadCnt

public int getThreadCnt()