java线程的超时控制
来源:优易学  2011-12-15 18:32:15   【优易学:中国教育考试门户网】   资料下载   IT书店

  下面这段代码在搜索java线程的超时控制时很容易被找到,并且结果的数量也不少。但是这段代码能够得到想要的结果么?

  开始的时候我一看这么多,也没多想,直接下载用了,但是程序里的bug依旧,以为程序里还有其它的问题,折腾了小半天,发现原来超时控制没有起作用,仔细核实了一下以下的代码,发现这段代码根本得到不到想要的结果。

  /**

  * 本线程设置了一个超时时间

  * 该线程开始运行后,经过指定超时时间,

  * 该线程会抛出一个未检查异常通知调用该线程的程序超时

  * 在超时结束前可以调用该类的cancel方法取消计时

  */

  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");

  }

  }

责任编辑:小草

文章搜索:
 相关文章
热点资讯
资讯快报
热门课程培训