也谈一谈Java线程的超时控制方法

2014-11-24 00:34:49 · 作者: · 浏览: 0

下面这段代码在搜索java线程的超时控制时很容易被找到,并且结果的数量也不少。但是这段代码能够得到想要的结果么
  开始的时候我一看这么多,也没多想,直接下载用了,但是程序里的bug依旧,以为程序里还有其它的问题,折腾了小半天,发现原来超时控制没有起作用,仔细核实了一下以下的代码,发现这段代码根本得到不到想要的结果。


 /**
  * 本线程设置了一个超时时间
  * 该线程开始运行后,经过指定超时时间,
  * 该线程会抛出一个未检查异常通知调用该线程的程序超时
  * 在超时结束前可以调用该类的cancel方法取消计时
  * @author solonote
  */
  public class TimeoutThread extends Thread{
  /**
  * 计时器超时时间
  */
  private long timeout;
  /**
  * 计时是否被取消
  */
  private boolean isCanceled = false;
  /**
  * 当计时器超时时抛出的异常
  */
  private TimeoutException timeoutException;
  /**
  * 构造器
  * @param timeout 指定超时的时间
  */
  public TimeoutThread(long timeout,TimeoutException timeoutErr) {
  super();
  this.timeout = timeout;
  this.timeoutException = timeoutErr;
  //设置本线程为守护线程
  this.setDaemon(true);
  }
  /**
  * 取消计时
  */
  public synchronized void cancel()
  {
  isCanceled = true;
  }
  /**
  * 启动超时计时器
  */
  public void run()
  {
  try {
  Thread.sleep(timeout);
  if(!isCanceled)
  throw timeoutException;
  } catch (InterruptedException e) {
  e.printStackTrace();
  }
  }
  }


  想起来socks有超时控制的代码,根踪了一下,发现它的超时控制直接延伸到native方法,看来不是在java层面的实现的,想来java的里想在一个线程里控制另外一个程序是不大容易了,那么只能设计一种替代的模式来工作了,还有别的路可以走么

 
 public class TestThreadTimeout extends Thread {
  public static void main(String[] args) {
  TestThreadTimeout ttt = new TestThreadTimeout();
  ttt.start();
  }
  public void run() {
  int timeout = 2000;
  TestThread task = new TestThread();
  task.start();
  try {
  task.join(timeout);
  } catch (InterruptedException e) {
  /* if somebody interrupts us he knowswhat he is doing */
  }
  if (task.isAlive()) {
  task.interrupt();
  System.out.println("超时啦。。。");
  throw new TimeoutException("xxx");
  } else {
  System.out.println("没超时...");
  }
  }
  }
  class TestThread extends Thread {
  public void run() {
  try {
  Thread.sleep(5000);
  System.out.println("ccccccccccccc");
  } catch (Exception ex) {
  ex.printStackTrace();
  }
  }
  //如果希望run中方法正常结束,覆盖interrupt方法
  public void interrupt() {
  System.out.println("qqqqqqqqqqqqqqqq");
  }
  }