JAVA技巧(JOTM中定時(shí)器的源碼分析)

JAVA技巧(JOTM中定時(shí)器的源碼分析)packageorg.objectweb.jotm;

importjava.util.Vector;

/**

*

*對(duì)計(jì)時(shí)器列表中的計(jì)時(shí)器進(jìn)展倒計(jì)時(shí)

*/

classClockextendsThread{

privateTimerManagertmgr;

publicClock(TimerManagertmgr){

super(“JotmClock“);

if(TraceTm.jta.isDebugEnabled()){

TraceTm.jta.debug(“Clockconstructor“);

}

this.tmgr=tmgr;

}

publicvoidrun(){

tmgr.clock();

}

}

/**

*

*Examda提示:出去計(jì)時(shí)器列表中的過(guò)期計(jì)時(shí)器，如倒計(jì)時(shí)為負(fù)數(shù)

*/

classBatchextendsThread{

privateTimerManagertmgr;

publicBatch(TimerManagertmgr){

super(“JotmBatch“);

if(TraceTm.jta.isDebugEnabled()){

TraceTm.jta.debug(“Batchconstructor“);

}

this.tmgr=tmgr;

}

publicvoidrun(){

tmgr.batch();

}

}

/**

*含有兩個(gè)計(jì)時(shí)器列表，并且含有兩個(gè)線程，一個(gè)線程進(jìn)展計(jì)時(shí)器的倒計(jì)時(shí)，

*一個(gè)線程移除過(guò)期計(jì)時(shí)器并且執(zhí)行計(jì)時(shí)器的監(jiān)聽(tīng)器動(dòng)作；

*/

publicclassTimerManager{

//threadsmanagingtheservice.

privatestaticBatchbatchThread;

privatestaticClockclockThread;

//lists

//計(jì)時(shí)器列表

privateVectortimerList=newVector();

//過(guò)期計(jì)時(shí)器列表

privateVectorexpiredList=newVector();

//單例

privatestaticTimerManagerunique=null;

privatestaticbooleanshuttingdown=false;

/**

*Constructor

*/

privateTimerManager(){

//launchthreadsfortimers

batchThread=newBatch(this);

batchThread.setDaemon(true);

batchThread.start();

clockThread=newClock(this);

clockThread.setDaemon(true);

clockThread.start();

}

/**

*這個(gè)時(shí)間治理器是一個(gè)單例類(lèi)；

*/

publicstaticTimerManagergetInstance(){

if(unique==null)

unique=newTimerManager();

returnunique;

}

//停頓時(shí)間治理器中的計(jì)時(shí)器；

publicstaticvoidstop(booleanforce){

if(TraceTm.jta.isDebugEnabled()){

TraceTm.jta.debug(“StopTimerManager“);

}

TimerManagertmgr=getInstance();

shuttingdown=true;

while(clockThread.isAlive()||batchThread.isAlive()){

try{

Thread.sleep(100);

}catch(InterruptedExceptione){

break;

}

}

if(TraceTm.jta.isDebugEnabled()){

TraceTm.jta.debug(“TimerManagerhasstopped“);

}

}

publicstaticvoidstop(){

stop(true);

}

/**

*cneyspeeduptheclockx1000whenshuttingdown

*updatealltimersinthelist

*eachtimerexpiredisputinaspeciallistofexpiredtimers

*theywillbeprocessedthenbytheBatchThread.

*/publicvoidclock(){

//無(wú)限循環(huán)

while(true){

try{

//線程休息一秒

Thread.sleep(shuttingdown?1:1000);//1secondor1msshenshuttingdown

//Thread.currentThread().sleep(shuttingdown?1:1000);//1secondor1msshenshuttingdown

synchronized(timerList){

intfound=0;

booleanempty=true;

for(inti=0;i0){

//喚醒線程；

timerList.notify();

}else{

if(empty

}

}

}

}catch(InterruptedExceptione){

TraceTm.jta.error(“Timerinterrupted“);

}

}

synchronized(timerList){//notifybatchsothatfunctioncanreturn.

timerList.notify();

}

}

/**

*processallexpiredtimers

*/

publicvoidbatch(){

while(!(shuttingdown

synchronized(timerList){

while(expiredList.isEmpty()){

if(shuttingdown)return;

try{

//計(jì)時(shí)器計(jì)時(shí)線程讓假如找到到期的計(jì)時(shí)器，那么就會(huì)喚醒執(zhí)行該計(jì)時(shí)器的線程執(zhí)行監(jiān)聽(tīng)器動(dòng)作

timerList.wait();

}catch(Exceptione){

TraceTm.jta.error(“ExceptioninBatch:“,e);

}

}

t=(TimerEvent)expiredList.elementAt(0);

expiredList.removeElementAt(0);

}

//執(zhí)行動(dòng)作；

cess();

}

}

/**

*addanewtimerinthelist

*@paramtelObjectthatwillbenotifiedwhenthetimerexpire.

*@paramtimeoutnbofsecondsbeforethetimerexpires.

*@paramarginfopassedwiththetimer

*@parampermanenttrueifthetimerispermanent.

*/

publicTimerEventaddTimer(TimerEventListenertel,longtimeout,Objectarg,booleanpermanent){

TimerEventte=newTimerEvent(tel,timeout,arg,permanent);

synchronized(timerList){

timerList.addElement(te);

}

returnte;

}

/**

*removeatimerfromthelist.thisis