java多线程Thread的超时中断的实现

需求：在一个扣款操做后，若是预付款帐户余额不足时，新启一个线程去调用短信平台的接口，超过30秒无响应时，自动关闭，并记录在数据库。

思路：对于这种与其余平台进行交互的需求，最好的设计思路就是使用MQ，只要成功放到消息队列之后，另外一个平台就能够在队列里读取到，不用担忧超时的问题。这次的需求是调用他们平台的接口，可能会出现三种状况：成功，失败，超时。成功，失败这些状况就不一一描述了。重点是超时，超时的因素有不少，很难去分析到，因此就选择在本平台设置超时时间，来对调用状况进行判断和记录，通常的超时时间设置是30秒。

实现：使用线程或者线程池。这里使用线程进行超时关闭，先设定一个A线程去调用接口，同时建立一个守护线程B来进行计时，当正常运行时，A线程收到回应，关闭线程。当出现超时状况，30秒事后，B线程跑出异常，A线程跳出循环。

代码：

线程A

 1 final Thread t = new Thread(){  2                         //自定义守护线程
 3                         TimeoutThread tTime = new TimeoutThread(30000,new TimeoutException("短信发送超时"),smsRequestService,feePrepay,contentType);  4                         public void run(){  5                             while (true){  6                                 try {  7  tTime.start();  8                                     new XIYSMSService().smsSendMssage(feePrepay,contentType,smsRequestService);  9  tTime.cancel(); 10                                     break; 11                                 } catch (Exception e) { 12  System.err.println(e); 13                                     break; 14  } 15  } 16  } 17                     };

守护线程B

 1 /**
 2 * 本线程设置了一个超时时间  3 * 该线程开始运行后，通过指定超时时间，  4 * 该线程会抛出一个未检查异常通知调用该线程的程序超时  5 * 在超时结束前能够调用该类的cancel方法取消计时  6 * @author liheng  7 */
 8 public class TimeoutThread extends Thread{  9 /**
10 * 计时器超时时间 11 */
12     private long timeout; 13 /**
14 * 计时是否被取消 15 */
16     private boolean isCanceled = false; 17 /**
18 * 当计时器超时时抛出的异常 19 */
20     
21     private TimeoutException timeoutException; 22     
23     private SmsRequestService smsRequestService; 24     
25     private FeePrepay feePrepay; 26     
27     private String contentType; 28 /**
29 * 构造器 30 * @param timeout 指定超时的时间 31 */
32 public TimeoutThread(long timeout,TimeoutException timeoutErr,SmsRequestService smsRequestService,FeePrepay feePrepay,String contentType) { 33     super(); 34     this.timeout = timeout; 35     this.timeoutException = timeoutErr; 36     this.smsRequestService = smsRequestService; 37     this.feePrepay = feePrepay; 38     this.contentType = contentType; 39     //设置本线程为守护线程
40     this.setDaemon(true); 41 } 42 /**
43 * 取消计时 44 */
45     public synchronized void cancel(){ 46         isCanceled = true; 47  } 48 /**
49 * 启动超时计时器 50 */
51     public void run(){ 52         try { 53  Thread.sleep(timeout); 54             if(!isCanceled){ 55                 smsRequestService.saveFeePrePay(feePrepay, "超时", contentType); 56  System.err.println(timeoutException); 57  } 58         } catch (InterruptedException e) { 59  System.err.println(e); 60  } 61  } 62 }

View Code

欢迎你们留言交流，指出不足之处，万分感谢！

原文出处：https://www.cnblogs.com/yiqi520/p/10286816.html