だから私はタイマーを作成する方法を理解しようとしています、私はこれに出くわしました： ScheduledExecutorServiceを使用してタイマーを開始および停止します
彼らが持っている例はかなりうまくいくようです。私はこれを正しく利用しているかどうか疑問に思っています:
public class TimerTest
{
private ScheduledExecutorService es = null;
private boolean timeIsUp = false;
private ScheduledFuture futureHandler = null;
private TimeKeeper timeKeeper = null;
private String subject = "";
private int siteNo;
private long time;
private boolean stop;
public void endTimer()
{
System.out.println("we should shutdown everything here");
es.shutdownNow();
}
public boolean stopTimer()
{
if (timeKeeper != null)
{
timeKeeper.deactivate();
}
futureHandler.cancel(true);
return true;
}
public boolean isTimeup()
{
return timeKeeper.isTimeUp();
}
public void startTimer(long mseconds, String subj, int sNo)
{
subject = subj;
siteNo = sNo;
time = mseconds;
timeKeeper = new TimeKeeper();
callScheduler(mseconds);
}
public boolean isTimerRunning()
{
return (es.isShutdown() || es == null);
}
public void resetTimer(long t)
{
stopTimer();
callScheduler(t);
}
public void resetTimer()
{
resetTimer(time);
}
private void callScheduler(long mseconds)
{
if (es == null)
es = Executors.newScheduledThreadPool(3);
timeKeeper = new TimeKeeper();
futureHandler = es.schedule( timeKeeper, mseconds, TimeUnit.MILLISECONDS);
}
private class TimeKeeper implements Runnable {
//volatile for thread-safety
private volatile boolean isActive = true;
private volatile boolean isTimeUp = false;
public void run () {
if (isActive){
callAlert();
isTimeUp = true;
}
}
public void deactivate(){
isActive = false;
}
public boolean isTimeUp()
{
return isTimeUp;
}
private void callAlert()
{
System.out.println("you are in the callAlert method");
}
}
}
そして、ここにテストがあります：
public static void main(String[] args) {
// TODO Auto-generated method stub
long pastTime = System.currentTimeMillis();
TimerTest timer = new TimerTest();
timer.startTimer(15000, "bh", 1);
long time;
int count =0;
boolean stop = false;
while(true)
{
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
time = System.currentTimeMillis() - pastTime;
if (time > 3000)
{
if (!stop){
System.out.println("we are reseting the timer");
timer.resetTimer(4000);
timer.stopTimer();
try {
Thread.sleep(3995);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
break;
}
stop = true;
}
if (timer.isTimeup())
{
System.out.println("our time is up");
timer.endTimer();
break;
}
if (!stop)
System.out.println("hello");
else
{
if (count == 0)
System.out.println("we wait 10 seconds from now");
count++;
}
}
timer.resetTimer(1200);
while (true)
{
if (timer.isTimeup())
{
timer.isTimeup();
System.out.println("breaking after time is up");
break;
}
}
timer.endTimer();
}
これは機能しているようです。必要なものを見逃している可能性があります。ScheduledExecutorService を使用するのはこれが初めてです。このコードに問題はありますか? スレッドの衝突と競合したくありません。