并发资源管理代码咨询：是否存在资源泄漏及优化方案

一、当前实现的资源泄漏风险 #

• Connection连接泄漏：当get(timeOut...)触发TimeoutException时，getConnection()可能已经成功获取到Connection，但此时这个Connection不会被try-with-resources接管（因为get()未正常返回，Connection变量未完成初始化）。而executor.shutdownNow()仅尝试中断任务线程，若getConnection()不响应线程中断（比如底层JDBC驱动不支持中断连接获取操作），任务会继续执行完成，拿到的Connection没有任何代码负责关闭，直接导致连接泄漏。
• 线程池资源浪费：每次业务逻辑执行都新建SingleThreadExecutor，线程的创建与销毁会带来不必要的性能开销；若任务未被中断，线程池也无法及时释放资源。

二、更优实现方案 #

1. 优先使用JDBC原生超时配置（推荐） #

大部分JDBC驱动和连接池本身支持连接超时配置，无需额外用线程池包装，这是最可靠且简洁的方式：

// 示例：通过DriverManager设置连接超时
Properties props = new Properties();
props.setProperty("user", "your_username");
props.setProperty("password", "your_password");
props.setProperty("connectTimeout", String.valueOf(timeOut.toMillis())); // 设置连接超时时间
try (Connection connection = DriverManager.getConnection("jdbc_url", props)) {
    // 执行业务逻辑
} catch (SQLException e) {
    // 日志记录，连接超时会被包含在SQLException的异常链中
}

如果使用连接池（如HikariCP、Druid），可直接在连接池配置中设置connectionTimeout参数，稳定性和兼容性远优于手动线程池包装方案。

2. 若必须用线程池包装，修复资源泄漏问题 #

如果因特殊场景必须用线程池做超时控制，需确保任务即使超时，已创建的Connection也能被关闭：

// 全局复用线程池，避免频繁创建销毁线程
private static final ExecutorService CONNECTION_EXECUTOR = Executors.newCachedThreadPool();

public void executeBusinessLogic() {
    Callable<Connection> connectionTask = () -> {
        Connection conn = null;
        try {
            conn = getConnection();
            // 检查线程是否被中断，若已中断则关闭连接并抛出异常
            if (Thread.currentThread().isInterrupted()) {
                conn.close();
                throw new InterruptedException("连接获取任务被中断");
            }
            return conn;
        } catch (Exception e) {
            // 无论是否异常，确保已创建的Connection被关闭
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException se) {
                    // 日志记录连接关闭失败
                }
            }
            throw e;
        }
    };

    Future<Connection> future = CONNECTION_EXECUTOR.submit(connectionTask);
    try (Connection connection = timeOut == null 
            ? future.get() 
            : future.get(timeOut.toMillis(), TimeUnit.MILLISECONDS)) {
        // 执行业务逻辑
    } catch (TimeoutException e) {
        // 超时后主动取消任务，true表示尝试中断任务线程
        future.cancel(true);
        // 日志记录超时事件
    } catch (InterruptedException e) {
        // 日志记录中断事件
        Thread.currentThread().interrupt();
    } catch (ExecutionException | SQLException e) {
        // 日志记录执行异常
    }
    // 注意：线程池为全局复用，仅在应用关闭时统一调用CONNECTION_EXECUTOR.shutdownNow()
}

核心改进点：在Callable内部添加Connection的异常处理与中断检查，确保只要创建了Connection，无论任务成功、失败还是被中断，都会被关闭；同时复用线程池，避免重复创建线程的性能损耗。

3. 使用CompletableFuture简化超时逻辑 #

Java 8+的CompletableFuture可以更简洁地实现超时控制，同时结合资源管理：

private static final ExecutorService CONNECTION_EXECUTOR = Executors.newCachedThreadPool();

public void executeBusinessLogic() {
    CompletableFuture<Connection> connectionFuture = CompletableFuture.supplyAsync(() -> {
        Connection conn = null;
        try {
            conn = getConnection();
            if (Thread.currentThread().isInterrupted()) {
                conn.close();
                throw new IllegalStateException("连接获取任务被中断");
            }
            return conn;
        } catch (Exception e) {
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException se) {
                    // 日志记录连接关闭失败
                }
            }
            throw new CompletionException(e);
        }
    }, CONNECTION_EXECUTOR);

    try (Connection connection = timeOut == null 
            ? connectionFuture.join() 
            : connectionFuture.get(timeOut.toMillis(), TimeUnit.MILLISECONDS)) {
        // 执行业务逻辑
    } catch (TimeoutException e) {
        connectionFuture.cancel(true);
        // 日志记录超时事件
    } catch (InterruptedException e) {
        Thread.currentThread().interrupt();
        // 日志记录中断事件
    } catch (ExecutionException | SQLException e) {
        // 日志记录执行异常
    }
}

内容的提问来源于stack exchange，提问作者Teddy Tsai