java多线程之FutureTask、Future、CompletableFuture

**Java 多线程之 FutureTask、Future 和 CompletableFuture**

在 Java 中，多线程编程是非常重要的概念。它可以帮助我们提高程序的并发性和性能。在本文中，我们将讨论三个相关的类：`FutureTask`、`Future` 和 `CompletableFuture`。

###1. FutureTask`FutureTask` 是一个实现了 `Runnable` 接口的类，它代表一个异步任务。它可以被提交到线程池中执行，并且可以等待任务完成后获取结果。

#### 构造方法：

javapublic FutureTask(Callable callable) {
 if (callable == null)
 throw new NullPointerException();
 this.callable = callable;
}

javaimport java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;

public class FutureTaskExample {
 public static void main(String[] args) throws ExecutionException, InterruptedException {
 // 创建一个FutureTask对象，传入Callable接口的实现类 Callable callable = new Callable() {
 @Override public String call() throws Exception {
 System.out.println("任务正在执行...");
 Thread.sleep(2000);
 return "任务完成";
 }
 };
 FutureTask futureTask = new FutureTask<>(callable);

 // 提交到线程池中执行 Thread thread = new Thread(futureTask);
 thread.start();

 // 等待任务完成后获取结果 String result = futureTask.get();
 System.out.println("结果：" + result);
 }
}

javaimport java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Future;

public class FutureExample {
 public static void main(String[] args) throws ExecutionException, InterruptedException {
 // 创建一个Future对象，传入Callable接口的实现类 Callable callable = new Callable() {
 @Override public String call() throws Exception {
 System.out.println("任务正在执行...");
 Thread.sleep(2000);
 return "任务完成";
 }
 };
 Future future = java.util.concurrent.Executors.newSingleThreadExecutor().submit(callable);

 // 等待任务完成后获取结果 String result = future.get();
 System.out.println("结果：" + result);
 }
}

javapublic static  CompletableFuture supplyAsync(Supplier supplier) {
 return supplyAsync(supplier, executor);
}

javaimport java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

public class CompletableFutureExample {
 public static void main(String[] args) throws ExecutionException, InterruptedException {
 // 创建一个CompletableFuture对象，传入Supplier接口的实现类 Supplier supplier = new Supplier() {
 @Override public String get() {
 System.out.println("任务正在执行...");
 Thread.sleep(2000);
 return "任务完成";
 }
 };
 CompletableFuture completableFuture = CompletableFuture.supplyAsync(supplier);

 // 等待任务完成后获取结果 String result = completableFuture.get();
 System.out.println("结果：" + result);
 }
}