带有时间限制的Runnable

试图构造一个必须在给定时间限制内结束的Runnable 。

目前我正在使用java.util.Timer来中断Runnable线程。

在Runnable启动后立即启动Timer 。

 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 !!"); } ...