阅读量:2
Java可以通过使用线程来实现任务超时处理。以下是一个简单的例子:
import java.util.concurrent.*; public class TimeoutExample { public static void main(String[] args) { ExecutorService executor = Executors.newSingleThreadExecutor(); // 创建一个Callable任务 Callable<String> task = () -> { // 模拟一个耗时的操作 Thread.sleep(5000); return "Task completed"; }; try { // 提交任务并设置超时时间为2秒 Future<String> future = executor.submit(task); String result = future.get(2, TimeUnit.SECONDS); System.out.println(result); } catch (TimeoutException e) { // 超时处理 System.out.println("Task timeout"); } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); } finally { executor.shutdownNow(); // 关闭线程池 } } }
在上面的例子中,我们创建了一个单线程的线程池,并提交了一个耗时的任务。通过Future
对象的get
方法来获取任务的结果,并设置了超时时间为2秒。如果任务在超时时间内没有完成,会抛出TimeoutException
,我们可以在catch块中做相应的处理。最后,记得要调用shutdownNow
方法关闭线程池。