ScheduledExecutorService를 사용하여 타이머를 시작 및 중지

Question

제 독서에서 ScheduledExecutorService는 Java에서 타이머를 시작하고 중지하는 올바른 방법입니다.

타이머를 시작하고 중지하는 코드를 포트해야합니다. 이것은주기적인 타이머가 아닙니다. 이 코드는 타이머를 시작하기 전에 타이머를 중지합니다. 그래서, 모든 시작은 실제로 재시작()입니다. ScheduledExecutorService를 사용하여이 작업을 수행 할 올바른 방법을 찾고 있습니다. 여기에 내가 생각해 낸 것이있다. 일 내가 놓친 거지에 대한 의견과 통찰력을 찾고 :

ScheduledExecutorService _Timer = Executors.newScheduledThreadPool(1); 
ScheduledFuture<?> _TimerFuture = null; 

private boolean startTimer() { 
    try { 
     if (_TimerFuture != null) { 
      //cancel execution of the future task (TimerPopTask()) 
      //If task is already running, do not interrupt it. 
      _TimerFuture.cancel(false); 
     } 

     _TimerFuture = _Timer.schedule(new TimerPopTask(), 
             TIMER_IN_SECONDS, 
             TimeUnit.SECONDS); 
     return true; 
    } catch (Exception e) { 
     return false; 
    } 
} 

private boolean stopTimer() { 
    try { 
     if (_TimerFuture != null) { 
      //cancel execution of the future task (TimerPopTask()) 
      //If task is already running, interrupt it here. 
      _TimerFuture.cancel(true); 
     } 

     return true; 
    } catch (Exception e) { 
     return false; 
    } 
} 

private class TimerPopTask implements Runnable { 
    public void run() { 
     TimerPopped(); 
    } 
} 

public void TimerPopped() { 
    //Do Something 
} 

TIA, 루블

이 문제처럼 보인다

Answer 1

:

당신의 취소 거짓을 전달하는 때문에

private boolean startTimer() { 
    // ...... 
     if (_TimerFuture != null) { 
      _TimerFuture.cancel(false); 
     } 

     _TimerFuture = _Timer.schedule(new TimerPopTask(), 
             TIMER_IN_SECONDS, 
             TimeUnit.SECONDS); 
    // ...... 
} 

작업이 이미 실행중인 경우 이전 _TimerFuture이 취소되지 않을 수 있습니다. 어쨌든 새로운 하나가 생성됩니다 (그러나 ExecutorService은 고정 된 스레드 풀 크기가 1이기 때문에 동시에 실행되지 않습니다). 어쨌든 startTimer()가 호출 될 때 타이머를 다시 시작할 때의 원하는 동작처럼 들리지는 않습니다.

나는 약간을 재 설계 할 것이다. 나는 TimerPopTask 인스턴스는 "취소"는 일이 될 만들 것, 그리고 나는 그들이이 생성되면 혼자 ScheduledFutures을 떠날 것이다 :가 startTimer를

private class TimerPopTask implements Runnable { 
    //volatile for thread-safety 
    private volatile boolean isActive = true; 
    public void run() { 
     if (isActive){ 
      TimerPopped(); 
     } 
    } 
    public void deactivate(){ 
     isActive = false; 
    } 
} 

그때 차라리 ScheduledFuture의 인스턴스보다 TimerPopTask의 인스턴스를 유지하는 것입니다 및 재 배열 thusly 히 방법 :

private TimerPopTask timerPopTask; 

private boolean startTimer() { 
    try { 
     if (timerPopTask != null) { 
      timerPopTask.deactivate(); 
     } 

     timerPopTask = new TimerPopTask(); 
     _Timer.schedule(timerPopTask, 
         TIMER_IN_SECONDS, 
         TimeUnit.SECONDS); 
     return true; 
    } catch (Exception e) { 
     return false; 
    } 
} 

(.하는 stopTimer와 마찬가지로 수정() 메소드)

당신은 당신이 진정으로 태어나 셨 예상되는 경우 스레드의 수를 크랭크 할 수 있습니다 딩은 '다시 시작'에 타이머가 현재의 타이머가 만료되기 전에 :

private ScheduledExecutorService _Timer = Executors.newScheduledThreadPool(5); 

당신은 내가 설명하고 또한 현재의 ScheduledFuture에로 현재 TimerPopTask 모두에 대한 참조를 유지, 하이브리드 접근 방식으로 가고 싶은 최고의 만들 수 있습니다 노력을 취소하고 가능하면 스레드를 무료로, 취소가 보장되지 않는다는 것을 이해합니다.

(참고 :..이 모두가 그렇지 않으면 추가 안전 장치가 필요합니다가 startTimer()와하는 stopTimer을() 메서드 호출이 하나의 메인 스레드에 국한되며, 단지 TimerPopTask 인스턴스 스레드간에 공유되는 가정)