Sha256: 10625135bb170c319b2c6eee7f846aa46da99ed5a19293be82dbcdbbd6b679e0
Contents?: true
Size: 1.55 KB
Versions: 8
Compression:
Stored size: 1.55 KB
Contents
package com.rho;
public class RhoThread extends Thread
{
private static final RhoLogger LOG = RhoLogger.RHO_STRIP_LOG ? new RhoEmptyLogger() :
new RhoLogger("RhoThread");
public final static int epNormal = 0, epHigh = 1, epLow = 2;
private Object m_syncObj = new Object();
boolean m_isInWaitState;
protected boolean m_bStop = false;
public RhoThread(RhoClassFactory factory)
{
m_isInWaitState = false;
}
public Object getSyncObject(){ return m_syncObj; }
public void start(int ePriority)
{
super.start();
int nThreadPriority = Thread.NORM_PRIORITY;
if ( ePriority == epHigh )
nThreadPriority = Thread.MAX_PRIORITY;
else if ( ePriority == epLow )
nThreadPriority = Thread.MIN_PRIORITY;
super.setPriority(nThreadPriority);
}
public void stop(int nTimeoutToKill)
{
m_bStop = true;
stopWait();
try{
int nTry = 0;
while( nTry < nTimeoutToKill*10 && super.isAlive() ){
Thread.sleep(100);
nTry++;
}
if ( super.isAlive() )
super.interrupt();
}catch(Exception e){
LOG.ERROR("stop failed", e);
}
}
public void wait(int nTimeout)
{
synchronized (m_syncObj) {
try{
m_isInWaitState = true;
m_syncObj.wait(nTimeout*1000);
}catch(Exception e)
{
LOG.ERROR("wait failed", e);
}finally{
m_isInWaitState = false;
}
}
}
public void stopWait()
{
synchronized (m_syncObj) {
if ( m_isInWaitState )
m_syncObj.notifyAll();
}
}
};
Version data entries
8 entries across 8 versions & 1 rubygems