如何创建一个在被调用时可以添加addOnSuccessListener的函数

import java.util.concurrent.CompletableFuture;
import java.util.function.Consumer;

public class AsyncFunctionExample {

    // 模拟一个异步操作
    public static CompletableFuture<String> asyncOperation() {
        return CompletableFuture.supplyAsync(() -> {
            try {
                // 模拟耗时操作
                Thread.sleep(2000);
            } catch (InterruptedException e) {
                throw new IllegalStateException(e);
            }
            return "Operation completed successfully!";
        });
    }

    // 创建一个可以添加addOnSuccessListener的函数
    public static void executeAsyncOperationWithSuccessListener(Consumer<String> successListener) {
        asyncOperation().thenAccept(successListener);
    }

    public static void main(String[] args) {
        // 使用函数并添加成功监听器
        executeAsyncOperationWithSuccessListener(result -> {
            System.out.println("Success: " + result);
        });

        // 防止主线程立即退出
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}