在Java中,可以使用ExecutorService來控制線程的超時時間并自動關閉線程。下面是一個示例代碼:
import java.util.concurrent.*;
public class ThreadTimeoutExample {
public static void main(String[] args) {
ExecutorService executor = Executors.newSingleThreadExecutor();
try {
Future<String> future = executor.submit(new Callable<String>() {
@Override
public String call() throws Exception {
// 在這里執行耗時操作
Thread.sleep(5000);
return "Task completed";
}
});
try {
String result = future.get(3, TimeUnit.SECONDS); // 設置超時時間為3秒
System.out.println(result);
} catch (TimeoutException e) {
System.out.println("Task timed out and will be cancelled");
future.cancel(true); // 取消任務
}
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
} finally {
executor.shutdown();
}
}
}
在上面的示例中,我們使用ExecutorService創建了一個單線程池,并提交了一個耗時5秒的任務。通過Future的get方法設置超時時間為3秒,如果任務在規定時間內未完成,則會拋出TimeoutException并取消任務。最后記得調用ExecutorService的shutdown方法關閉線程池。