Java Future超时后，如何清理未获取到的CloseableResource资源？

你遇到的核心问题是：超时放弃等待后，异步任务可能仍在运行并最终返回资源，但主线程无法获取句柄导致泄漏。以下是几种可靠的解决思路：

方案一：自定义FutureTask重写done()方法 #

通过重写FutureTask的done()方法，在任务完成时自动检查资源是否被主线程获取，未被获取则立即清理：

class ResourceFutureTask extends FutureTask<CloseableResource> {
    private CloseableResource acquiredResource;

    public ResourceFutureTask(Callable<CloseableResource> callable) {
        super(callable);
    }

    @Override
    protected void done() {
        // 任务完成后触发，此时get()不会阻塞
        if (!isCancelled() && acquiredResource == null) {
            try {
                CloseableResource unusedResource = get();
                unusedResource.close();
            } catch (InterruptedException | ExecutionException e) {
                // 记录异常日志即可
            }
        }
    }

    @Override
    public CloseableResource get() throws InterruptedException, ExecutionException {
        acquiredResource = super.get();
        return acquiredResource;
    }

    @Override
    public CloseableResource get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException {
        acquiredResource = super.get(timeout, unit);
        return acquiredResource;
    }
}

使用方式：

ResourceFutureTask task = new ResourceFutureTask(() -> getCloseableResource());
executorService.submit(task);

try {
    CloseableResource cr = task.get(TIMEOUT, TimeUnit.MILLISECONDS);
    // 用try-with-resources自动管理资源生命周期
    try (cr) {
        // 执行业务逻辑
    }
} catch (TimeoutException e) {
    // 尝试中断任务（如果getCloseableResource响应中断的话）
    task.cancel(true);
} catch (InterruptedException | ExecutionException e) {
    // 处理任务执行异常
}

逻辑说明：主线程成功获取资源时，acquiredResource会被赋值，done()方法不会执行清理；如果超时放弃，任务后续完成时acquiredResource仍为null，就会自动关闭资源。

方案二：使用CompletableFuture的回调机制 #

CompletableFuture支持添加任务完成后的回调，可在回调中判断资源是否被主线程获取，未获取则清理：

AtomicBoolean isResourceTaken = new AtomicBoolean(false);
CompletableFuture<CloseableResource> future = CompletableFuture.supplyAsync(
    () -> getCloseableResource(),
    executorService
);

try {
    CloseableResource cr = future.get(TIMEOUT, TimeUnit.MILLISECONDS);
    isResourceTaken.set(true);
    try (cr) {
        // 业务逻辑处理
    }
} catch (TimeoutException e) {
    // 尝试取消任务
    future.cancel(true);
} catch (InterruptedException | ExecutionException e) {
    // 处理异常
}

// 任务完成后触发的回调，清理未被取走的资源
future.whenComplete((resource, throwable) -> {
    if (resource != null && !isResourceTaken.get()) {
        try {
            resource.close();
        } catch (Exception e) {
            // 记录清理异常
        }
    }
});

逻辑说明：用AtomicBoolean标记资源是否被主线程获取，回调中根据标记决定是否清理资源，避免主线程已使用的资源被误关闭。

方案三：中断任务（依赖方法响应中断） #

如果getCloseableResource()内部能响应线程中断（比如包含可中断的阻塞操作，会抛出InterruptedException），超时后直接中断任务，阻止资源被创建或返回：

Future<CloseableResource> future = executorService.submit(() -> {
    try {
        return getCloseableResource();
    } catch (InterruptedException e) {
        // 恢复中断状态，不影响后续线程逻辑
        Thread.currentThread().interrupt();
        return null;
    }
});

try {
    CloseableResource cr = future.get(TIMEOUT, TimeUnit.MILLISECONDS);
    try (cr) {
        // 业务逻辑
    }
} catch (TimeoutException e) {
    // 中断任务，阻止资源继续创建
    future.cancel(true);
} catch (InterruptedException | ExecutionException e) {
    // 处理异常
}

注意：如果getCloseableResource()不响应中断，这个方法只能终止任务线程，但无法阻止资源被创建和返回，必须结合方案一或二的清理逻辑。

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