java多線程Thread的超時中斷的實現

需求：在一個扣款操作后，如果預付款賬戶余額不足時，新啟一個線程去調用短信平台的接口，超過30秒無響應時，自動關閉，並記錄在數據庫。

思路：對於這種與其他平台進行交互的需求，最好的設計思路就是使用MQ，只要成功放到消息隊列以后，另一個平台就可以在隊列里讀取到，不用擔心超時的問題。此次的需求是調用他們平台的接口，可能會出現三種情況：成功，失敗，超時。成功，失敗這些情況就不一一描述了。重點是超時，超時的因素有很多，很難去分析到，所以就選擇在本平台設置超時時間，來對調用情況進行判斷和記錄，一般的超時時間設置是30秒。

實現：使用線程或者線程池。這里使用線程進行超時關閉，先設定一個A線程去調用接口，同時創建一個守護線程B來進行計時，當正常運行時，A線程收到回應，關閉線程。當出現超時情況，30秒過后，B線程跑出異常，A線程跳出循環。

代碼：

線程A

final Thread t = new Thread(){
                        //自定義守護線程
                        TimeoutThread tTime = new TimeoutThread(30000,new TimeoutException("短信發送超時"),smsRequestService,feePrepay,contentType);
                        public void run(){
                            while (true){    
                                try {
                                    tTime.start();
                                    new XIYSMSService().smsSendMssage(feePrepay,contentType,smsRequestService);
                                    tTime.cancel();
                                    break;
                                } catch (Exception e) {
                                    System.err.println(e);
                                    break;
                                }
                            }
                        }
                    };

守護線程B

/**
* 本線程設置了一個超時時間
* 該線程開始運行后，經過指定超時時間，
* 該線程會拋出一個未檢查異常通知調用該線程的程序超時
* 在超時結束前可以調用該類的cancel方法取消計時
* @author liheng
*/
public class TimeoutThread extends Thread{
/**
* 計時器超時時間
*/
    private long timeout;
/**
* 計時是否被取消
*/
    private boolean isCanceled = false;
/**
* 當計時器超時時拋出的異常
*/
    
    private TimeoutException timeoutException;
    
    private SmsRequestService smsRequestService;
    
    private FeePrepay feePrepay;
    
    private String contentType;
/**
* 構造器
* @param timeout 指定超時的時間
*/
public TimeoutThread(long timeout,TimeoutException timeoutErr,SmsRequestService smsRequestService,FeePrepay feePrepay,String contentType) {
    super();
    this.timeout = timeout;
    this.timeoutException = timeoutErr;
    this.smsRequestService = smsRequestService;
    this.feePrepay = feePrepay;
    this.contentType = contentType;
    //設置本線程為守護線程
    this.setDaemon(true);
}
/**
* 取消計時
*/
    public synchronized void cancel(){
        isCanceled = true;
    }
/**
* 啟動超時計時器
*/
    public void run(){
        try {
            Thread.sleep(timeout);
            if(!isCanceled){
                smsRequestService.saveFeePrePay(feePrepay, "超時", contentType);
                System.err.println(timeoutException);
            }
        } catch (InterruptedException e) {
            System.err.println(e);
            }
        }
}

歡迎大家留言交流，指出不足之處，萬分感謝！