可運行時間限制

Question

試圖構建Runnable即必須在給定的時間限制內結束。

當前我正在使用java.util.Timer中斷Runnable線程。

Timer在Runnable開始後立即開始。

import java.util.Timer; 
import java.util.TimerTask; 

public class test { 
    Thread task; 
    Timer timer; 

    public void start(){ 

     task = new Thread(new worker()); 
     timer = new Timer("timer",true); 

     task.start(); 
     timer.schedule(new Terminator(),1000*2); 
    } 


    class worker implements Runnable{ 
     @Override 
     public void run() { 

      for (int i = 0 ; i < 2; i++){ 
       try { 
        Thread.sleep(1000); 
       } catch (InterruptedException e) { 
        System.out.println("Test Interrupted !!"); 
        return; 
       } 
      } 

      System.out.println("Test Finished !!"); 
      timer.cancel(); 
     } 
    } 

    class Terminator extends TimerTask{ 
     @Override 
     public void run() { 
      task.interrupt(); 
      System.out.println("Test Terminated !!"); 
     } 
    } 
} 

但我懷疑這會導致競爭條件Timer和Runnable線程之間： Runnable即將完成，並Timer也燒成。

這可以導致這兩個成品!!和終止！正在打印？如果是這樣，如何避免它？

更新：

它發生：

11-09 21:14:40.741: INFO/System.out(31442): Test Finished !! 18 
11-09 21:14:40.751: INFO/System.out(31442): Test Terminated !! 18 
11-09 21:14:40.751: INFO/System.out(31442): Test Finished !! 19 
11-09 21:14:40.751: INFO/System.out(31442): Test Terminated !! 19 

Answer 1

可這個不斷導致兩個成品！並終止！正在印刷？

是的。當打印「完成」信息時，定時器可能會在取消之前觸發。

System.out.println("Finished !!"); 
// The timer can fire here. 
timer.cancel(); 

如果發生這種情況，將會打印這兩條消息。

---

要避免此問題，您可以使用同步。

synchronized (someObject) { 
    if (!finished) { 
     finished = true; 
     System.out.println("Finished !!"); 
     timer.cancel(); 
    } 
} 

而在終止子：

synchronized (someObject) { 
    if (!finished) { 
     finished = true; 
     task.interrupt(); 
     System.out.println("Test Terminated !!"); 
    } 
} 

這防止形成被打印兩個消息。

Answer 2

是的。如果你想避免這種情況，你需要使用synchronize和共享鎖對象：

public class test { 
    private Object lock = new Object(); 
    ... 

     synchronized(lock) { 
      System.out.println("Test Finished !!"); 
      timer.cancel(); 
     } 
    ... 

     synchronized(lock) { 
      if(! task.isRunning()) return; 

      task.interrupt(); 
      System.out.println("Test Terminated !!"); 
     } 

    ...