要为线程建立时间限制,请考虑使用 ExecutorService 而不是 Timer。 ExecutorService 提供了一种灵活的解决方案,用于控制线程在指定时间内执行。
这是使用 ExecutorService 的精炼代码片段:
import java.util.concurrent.*; public class ThreadTimeout { public static void main(String[] args) throws Exception { ExecutorService executor = Executors.newSingleThreadExecutor(); Future<String> future = executor.submit(new Task()); try { System.out.println("Started.."); System.out.println(future.get(3, TimeUnit.SECONDS)); System.out.println("Finished!"); } catch (TimeoutException e) { future.cancel(true); System.out.println("Terminated!"); } executor.shutdownNow(); } static class Task implements Callable<String> { @Override public String call() throws Exception { // Your long-running task should go here. return "Ready!"; } } }
通过利用 Future#get(),您可以建立一个任务超时。如果任务在该时间内完成,则会按预期检索结果。但是,如果未能在指定时间内完成,则会执行 catch 块,从而允许您取消任务。
关于 sleep() 用法的说明
所提供的示例中包含 sleep() 仅用于演示目的。它旨在模拟 SSCCE 中长时间运行的任务。在您的实际场景中,将 sleep() 替换为您想要的长时间运行的任务。
为了避免潜在的死锁,定期检查长时间运行的任务中您的线程是否已被中断至关重要,如以下代码片段:
while (!Thread.interrupted()) { // Perform your long-running task here. }
这种有条不紊的方法将确保您的线程及时响应中断请求并在超时时优雅地终止。
以上是Java中如何精确地使线程超时?的详细内容。更多信息请关注PHP中文网其他相关文章!