completablefuture 的 complete() 方法用于手动将任务标记为已完成，并设置结果值。调用该方法后，所有已注册的完成回调（如 thenapply、thenaccept）会立即在调用线程中同步执行。如果任务已经完成或已被取消，再次调用 complete() 将返回 false 且不会触发任何操作。
如何验证 complete() 触发的同步回调行为
要验证 complete() 的同步特性，可以创建一个未绑定的 CompletableFuture，注册一个打印当前线程名的回调，然后调用 complete()。观察发现，回调是在主线程执行的，而非异步线程池。
import java.util.concurrent.CompletableFuture;
public class Main {
public static void main(String[] args) {
CompletableFuture<String> future = new CompletableFuture<>();
// 注册一个完成回调
future.thenAccept(result -> {
System.out.println("Callback executed by: " + Thread.currentThread().getName());
System.out.println("Result: " + result);
});
// 手动完成
boolean completed = future.complete("Success");
System.out.println("Completed: " + completed);
}
}
complete() 与 supplyAsync 的区别是什么
supplyAsync 是异步执行任务并自动完成 Future，而 complete() 是直接设置结果。使用 supplyAsync 时，任务提交到 ForkJoinPool 后由工作线程执行；使用 complete() 时，没有后台任务，直接赋值。若需模拟外部数据源填充，应使用 complete()。
立即学习“Java免费学习笔记（深入）”；
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class Main {
public static void main(String[] args) throws ExecutionException, InterruptedException {
// 方式一：supplyAsync
CompletableFuture<String> asyncFuture = CompletableFuture.supplyAsync(() -> {
return "Async Result";
});
System.out.println("Async: " + asyncFuture.get());
// 方式二：complete
CompletableFuture<String> manualFuture = new CompletableFuture<>();
manualFuture.complete("Manual Result");
System.out.println("Manual: " + manualFuture.get());
}
}
complete() 在并发场景下如何处理重复调用
在并发场景中，多个线程可能同时尝试调用 complete()。此时只有第一个成功调用的线程会设置结果并触发回调，后续调用将返回 false 且被忽略。这种机制保证了结果的一致性，避免了竞态条件导致的多次执行。
