Class MonitoredThread.MultiThreadMonitor
- java.lang.Object
-
- org.eclipse.net4j.util.concurrent.MonitoredThread.MultiThreadMonitor
-
- All Implemented Interfaces:
java.lang.Runnable,MonitoredThread.ThreadMonitor
- Enclosing class:
- MonitoredThread
public static class MonitoredThread.MultiThreadMonitor extends java.lang.Object implements MonitoredThread.ThreadMonitor, java.lang.Runnable
- Author:
- Eike Stepper
-
-
Field Summary
Fields Modifier and Type Field Description static longSYNCED_START
-
Constructor Summary
Constructors Constructor Description MultiThreadMonitor(long timeOut)Same as calling MonitoredThread(idleTimeOut, SYNCED_START).MultiThreadMonitor(long idleTimeOut, long startOffset)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddThread(MonitoredThread thread)longgetIdleTimeOut()voidhandleFinished(MonitoredThread thread)voidhandleStarting(MonitoredThread thread)protected voidhandleTimeoutExpiration(MonitoredThread thread)voidrun()
-
-
-
Field Detail
-
SYNCED_START
public static final long SYNCED_START
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
MultiThreadMonitor
public MultiThreadMonitor(long idleTimeOut, long startOffset)- Parameters:
idleTimeOut- The number of milli seconds one of the threads may be idle (i.e. not having calledMonitoredThread.heartBeat()) beforehandleTimeoutExpiration(MonitoredThread)is called.startOffset- The number of milli seconds to sleep between threads are started. Zero means not to sleep andSYNCED_STARTmeans that all threads start at the same time by waiting on a shared latch.
-
MultiThreadMonitor
public MultiThreadMonitor(long timeOut)
Same as calling MonitoredThread(idleTimeOut, SYNCED_START).
-
-
Method Detail
-
getIdleTimeOut
public long getIdleTimeOut()
-
addThread
public void addThread(MonitoredThread thread)
-
handleStarting
public void handleStarting(MonitoredThread thread)
- Specified by:
handleStartingin interfaceMonitoredThread.ThreadMonitor
-
handleFinished
public void handleFinished(MonitoredThread thread)
- Specified by:
handleFinishedin interfaceMonitoredThread.ThreadMonitor
-
run
public void run()
- Specified by:
runin interfacejava.lang.Runnable
-
handleTimeoutExpiration
protected void handleTimeoutExpiration(MonitoredThread thread)
-
-