当前位置：首页 > Java

java如何超时处理

2026-03-24 18:00:36Java

Java 超时处理方法

在 Java 中处理超时通常涉及多线程、异步任务或网络请求等场景。以下是几种常见的超时处理方式：

使用 `Future` 和 `ExecutorService`

通过 ExecutorService 提交任务并设置超时时间，利用 Future.get() 方法实现超时控制。

ExecutorService executor = Executors.newSingleThreadExecutor();
Future<String> future = executor.submit(() -> {
    // 长时间运行的任务
    return "Task Result";
});

try {
    String result = future.get(5, TimeUnit.SECONDS); // 设置超时时间为5秒
    System.out.println(result);
} catch (TimeoutException e) {
    System.out.println("任务超时");
    future.cancel(true); // 取消任务
} catch (Exception e) {
    e.printStackTrace();
} finally {
    executor.shutdown();
}

使用 `CompletableFuture` 的 `orTimeout`

Java 9 及以上版本支持 CompletableFuture.orTimeout() 方法，可直接设置超时。

CompletableFuture.supplyAsync(() -> {
    // 模拟长时间任务
    try {
        Thread.sleep(10000);
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
    return "Done";
}).orTimeout(2, TimeUnit.SECONDS) // 设置2秒超时
  .exceptionally(ex -> "Timeout Occurred")
  .thenAccept(System.out::println);

网络请求超时

对于 HTTP 请求，可以通过 HttpURLConnection 或第三方库（如 OkHttp）设置超时。

HttpURLConnection 示例：

URL url = new URL("https://example.com");
HttpURLConnection connection = (HttpURLConnection) url.openConnection();
connection.setConnectTimeout(5000); // 连接超时5秒
connection.setReadTimeout(5000);    // 读取超时5秒

try {
    int responseCode = connection.getResponseCode();
    System.out.println(responseCode);
} catch (SocketTimeoutException e) {
    System.out.println("请求超时");
}

OkHttp 示例：

OkHttpClient client = new OkHttpClient.Builder()
    .connectTimeout(10, TimeUnit.SECONDS)
    .readTimeout(10, TimeUnit.SECONDS)
    .build();

Request request = new Request.Builder()
    .url("https://example.com")
    .build();

try (Response response = client.newCall(request).execute()) {
    System.out.println(response.body().string());
} catch (IOException e) {
    System.out.println("请求失败: " + e.getMessage());
}

使用 `Thread.join` 超时

等待线程完成时，可以通过 Thread.join() 设置超时时间。

Thread thread = new Thread(() -> {
    try {
        Thread.sleep(10000);
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
    }
});
thread.start();

try {
    thread.join(2000); // 等待2秒
    if (thread.isAlive()) {
        System.out.println("线程未完成，超时中断");
        thread.interrupt();
    }
} catch (InterruptedException e) {
    Thread.currentThread().interrupt();
}

数据库查询超时

对于 JDBC 操作，可以通过 Statement.setQueryTimeout() 设置超时。

java如何超时处理

try (Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "user", "password");
     Statement stmt = conn.createStatement()) {
    stmt.setQueryTimeout(5); // 设置查询超时5秒
    ResultSet rs = stmt.executeQuery("SELECT * FROM large_table");
    while (rs.next()) {
        System.out.println(rs.getString(1));
    }
} catch (SQLTimeoutException e) {
    System.out.println("数据库查询超时");
}