在 JDK 21 中，虚拟线程与 Future 的结合为异步编程提供了更强大和高效的解决方案。

Future 代表了异步计算的结果，通过它可以获取计算的状态和最终的结果。当与虚拟线程一起使用时，可以更灵活地管理和协调异步任务。

例如，在一个数据处理的场景中，需要从多个数据源获取数据并进行合并处理。可以使用虚拟线程来并发地从不同数据源获取数据，并将每个获取任务的结果封装在 Future 中。

以下是一个示例代码：

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class VirtualThreadWithFutureExample {public static void main(String[] args) {// 创建虚拟线程执行器ExecutorService executor = Executors.newVirtualThreadPerTaskExecutor();CompletableFuture<String> dataSource1Future = CompletableFuture.supplyAsync(() -> {// 模拟从数据源 1 获取数据System.out.println("Fetching data from Data Source 1");try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}return "Data from Source 1";}, executor);CompletableFuture<String> dataSource2Future = CompletableFuture.supplyAsync(() -> {// 模拟从数据源 2 获取数据System.out.println("Fetching data from Data Source 2");try {Thread.sleep(3000);} catch (InterruptedException e) {e.printStackTrace();}return "Data from Source 2";}, executor);// 等待两个 Future 都完成，并合并结果CompletableFuture<Void> combinedFuture = CompletableFuture.allOf(dataSource1Future, dataSource2Future).thenRun(() -> {try {// 假设 dataSource1Future 和 dataSource2Future 是 CompletableFuture 类型String dataSource1Result = dataSource1Future.join();String dataSource2Result = dataSource2Future.join();System.out.println("Combined Results: " + dataSource1Result + ", " + dataSource2Result);} catch (CompletionException e) {// 处理 CompletableFuture 特有的异常Throwable realException = e.getCause();realException.printStackTrace();}});executor.shutdown();}
}