如何为ListenableFuture执行耗时进行计时？

你的尝试方案是可行的，核心疑问的答案很明确：Lambda表达式会持有timer的强引用，而ListenableFuture会持有这个Lambda的引用，只要Future还未完成，timer就不会被垃圾回收。当Future执行完成（无论成功还是失败），监听线程会执行Lambda调用timer.close()，此时timer的状态是完全正常的。

为什么同步方案不可行 #

你提到的同步try-with-resources写法仅会记录thirdPartyLib.readDatabase()方法的返回耗时（也就是Future对象的创建时间），而非异步任务实际执行完成的总耗时——因为try块在Future返回后就会立即执行timer.close()，这显然不符合异步计时的需求。

你的尝试方案的合理性 #

这段代码是正确的：

public ListenableFuture doSomethingAsync() {
  MyTimer timer = new MyTimer();
  ListenableFuture future = thirdPartyLib.readDatabase();
  future.addListener(() -> timer.close(), listeningExecutorService);
  return future;
}

• Lambda捕获了timer变量，形成了强引用链：ListenableFuture → Listener（Lambda） → MyTimer
• 只要Future处于未完成状态，这条引用链就会阻止timer被GC回收；当Future完成后，Listener执行timer.close()记录耗时，之后引用链断开，timer才会被GC处理。

可选优化：覆盖异常场景（如果需要） #

如果你的MyTimer需要区分任务成功/失败的耗时统计，可以改用Futures.addCallback来分别处理：

public ListenableFuture doSomethingAsync() {
  MyTimer timer = new MyTimer();
  ListenableFuture future = thirdPartyLib.readDatabase();
  Futures.addCallback(future, new FutureCallback<Object>() {
    @Override
    public void onSuccess(@Nullable Object result) {
      // 记录成功耗时
      timer.close();
    }

    @Override
    public void onFailure(Throwable t) {
      // 记录失败耗时，也可以额外记录异常信息
      timer.close();
    }
  }, listeningExecutorService);
  return future;
}

不过如果你的MyTimer的close()方法本身不区分成功失败，只是单纯记录总耗时，那么最初的addListener写法已经足够简洁。

注意事项 #

• 确保listeningExecutorService是一个存活的线程池，避免因为线程池关闭导致Listener无法执行，从而遗漏耗时记录。
• 如果MyTimer的close()方法可能抛出异常，建议在Lambda中添加异常捕获，避免影响其他逻辑：

future.addListener(() -> {
  try {
    timer.close();
  } catch (Exception e) {
    // 处理close时的异常，比如日志记录
  }
}, listeningExecutorService);

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