在Java多线程编程中，`ListeningExecutorService` 是一个强大的工具，它能够监听任务的执行状态并返回结果。相比传统的 `ExecutorService`，它提供了更便捷的操作方式。通过引入 `ListenableFuture`，我们可以轻松地为异步任务添加回调函数，从而实现更加灵活的任务处理。

首先，我们需要通过 Guava 库来创建一个 `ListeningExecutorService` 实例。例如：

```java

ListeningExecutorService service = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(5));

```

接着，提交任务时，我们获得的是一个 `ListenableFuture` 对象。利用这个对象，可以非常方便地注册监听器，比如：

```java

ListenableFuture future = service.submit(() -> "任务已完成");

Futures.addCallback(future, new FutureCallback() {

@Override

public void onSuccess(String result) {

System.out.println("任务成功：" + result);

}

@Override

public void onFailure(Throwable t) {

System.err.println("任务失败：" + t.getMessage());

}

});

```

这种方式不仅简化了代码逻辑，还增强了程序的可读性和健壮性。无论是处理耗时计算还是网络请求，`ListeningExecutorService` 都能让你事半功倍！✨

Java 多线程 异步编程