java线程超时控制的实现

一.何时需要超时控制

     超时控制一般使用阻塞时间比较长的操作上,有可能是和远程数据库的连接,也有可能是网络下载,在程序超时后, 往往需要进行一些操作,比如退出线程,或者重新执行.

二.实现方法

方法1.(原创)

实现描述:使用一个守护线程作为计时器,并且在计时结束时抛出一个未检测异常。

具体实现:

类1:守护线程类

/**
* 本线程设置了一个超时时间
* 该线程开始运行后，经过指定超时时间，
* 该线程会抛出一个未检查异常通知调用该线程的程序超时
* 在超时结束前可以调用该类的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();
   }   
}
}

注: 类一中的TimeoutException是下边的用户自定义类，不是java中的java.util.concurrent.TimeoutException

类2.抛出异常类,该类继承了RuntimeException，原因是run方法不能抛出已检测异常。

public class TimeoutException extends RuntimeException {

/**
* 序列化号
*/
private static final long serialVersionUID = -8078853655388692688L;

public TimeoutException(String errMessage)
{
   super(errMessage);
}
}

使用方法:

   //初始化超时类
   TimeoutThread t = new TimeoutThread(5000,new TimeoutException("超时"));
   try{
    t.start();
    .....要检测超时的程序段....
    t.cancel();  
   }catch (TimeoutException e)
   {
    ...对超时的处理...
   }

TimeoutException可以更换为其他未检查异常类。

方法说明:

本方法的使用可以实现线程自己管理超时,并且可以管理某一段代码超时时,可以在方法内部给出处理办法。

但是需要注意的是:本方法的超时时间并不是当前线程的运行时间,而是计时器开始计时起系统运行的时间。

方法2:

     是用join方法,在外部管理线程超时。Thread对象有一个join(long millis)方法，执行该方法时如果另一个线程中断了当前线程,就会抛出一个InterruptedException异常。可以采用这个机制在一个线程的外部处理这个线程的异常。我觉得这个方法很有局限性，因为是在外部定义该线程的方法，就只能对整个线程的run方法做出线程超时控制，而并不是对run方法中的某一段代码。并且该方法处理线程超时的处理方法也只能写在线程的外部。不过这个方法的超时定义是当前线程的运行时间。

问题：运行main的时候怎么捕获不到 TimeoutException

把start()换成run()就可以捕捉到异常
因为异常是run()方法抛出的 而start()并不是类中的方法
不过用run()代替start()的话就无法是实现多线程了
不清楚lz究竟要做什么 只能先实现你的捕捉异常了

start()方法是启动（即开辟)一个线程的方法，因此线程的启动必须通过此方法，
而run()方法，只是Thread类的一个方法，它本身并不能开辟线程。
所以，用run()时候，程序只有一个线程，根本没达到你多线程的目的（是错误的）。
而用start()时候，你的程序又开辟了两个线程，所以结果不同