您好,登錄后才能下訂單哦!
Java中怎么實現線程超時控制,相信很多沒有經驗的人對此束手無策,為此本文總結了問題出現的原因和解決方法,通過這篇文章希望你能解決這個問題。
一.Java線程何時需要超時控制
超時控制一般使用阻塞時間比較長的操作上,有可能是和遠程數據庫的連接,也有可能是網絡下載,在程序超時后, 往往需要進行一些操作,比如退出線程,或者重新執行.
二.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();}}} |
注: 類1中的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); }} |
使用方法:
|
方法說明:
本方法的使用可以實現線程自己管理超時,并且可以管理某一段代碼超時時,可以在方法內部給出處理辦法。但是需要注意的是:本方法的超時時間并不是當前線程的運行時間,而是計時器開始計時起系統運行的時間。
方法2:
是用join方法,在外部管理線程超時。Thread對象有一個join(long millis)方法,執行該方法時如果另一個線程中斷了當前線程,就會拋出一個InterruptedException異常。可以采用這個機制在一個線 程的外部處理這個線程的異常。我覺得這個方法很有局限性,因為是在外部定義該線程的方法,就只能對整個線程的run方法做出線程超時控制,而并不是對 run方法中的某一段代碼。并且該方法處理線程超時的處理方法也只能寫在線程的外部。不過這個方法的超時定義是當前線程的運行時間。
看完上述內容,你們掌握Java中怎么實現線程超時控制的方法了嗎?如果還想學到更多技能或想了解更多相關內容,歡迎關注億速云行業資訊頻道,感謝各位的閱讀!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。