在Java中實現線程超時自動關閉可以使用兩種方式:使用Timer類或使用Future接口。
Timer timer = new Timer();
timer.schedule(new TimerTask() {
@Override
public void run() {
// 線程超時時關閉線程
thread.interrupt(); // thread為要關閉的線程
}
}, timeout);
Thread thread = new Thread() {
@Override
public void run() {
// 線程邏輯代碼
}
};
thread.start();
在上述代碼中,使用Timer類創建一個定時器,在指定的超時時間后調用TimerTask的run方法,從而執行線程的中斷操作。
ExecutorService executor = Executors.newSingleThreadExecutor();
Future<?> future = executor.submit(new Runnable() {
@Override
public void run() {
// 線程邏輯代碼
}
});
try {
future.get(timeout, TimeUnit.MILLISECONDS);
} catch (TimeoutException e) {
// 超時異常處理
} finally {
future.cancel(true);
executor.shutdown();
}
在上述代碼中,使用ExecutorService創建一個線程池,通過submit方法提交一個Runnable任務并返回一個Future對象。然后使用future.get方法設置超時時間,如果任務在指定時間內未完成,則拋出TimeoutException異常,可以在catch塊中進行超時異常處理。最后,使用future.cancel方法取消任務并關閉線程池。