Kotlin提取高阶函数后whenComplete回调未执行问题求助

你遇到的问题核心是提取闭包到单独函数后，whenComplete的回调未触发，导致extracted方法没执行，大概率是函数传递或类型适配的问题，以下是常见原因和解决办法：

1. 错误提前执行了回调逻辑 #

如果你的myFunction定义时，直接在函数内部调用了extracted，而非把extracted的调用逻辑封装到返回的闭包里，就会出现「调用myFunction时extracted执行一次，但Future完成时无回调」的情况。

错误示例：

fun myFunction(ctx: Ctx, payload: Payload): (Throwable?, Result?) -> Unit {
    // 这里直接执行了extracted，属于提前触发
    extracted(ctx, payload, null, null)
    // 返回的是空回调，Future完成时不会执行任何逻辑
    return { _, _ -> }
}

修正写法：

fun myFunction(ctx: Ctx, payload: Payload): (Throwable?, Result?) -> Unit {
    // 把extracted的调用逻辑封装到返回的闭包中，留到Future完成时执行
    return { throwable, result ->
        extracted(ctx, payload, throwable, result)
    }
}

2. Kotlin函数类型与Java BiConsumer的适配问题 #

Java的CompletableFuture.whenComplete接受的是BiConsumer<? super T, ? super U>接口，虽然Kotlin通常会自动做SAM转换，但如果你的myFunction返回的是Kotlin原生函数类型，在泛型参数复杂的场景下可能转换失效，导致回调未被正确注册。

解决办法：显式返回BiConsumer类型

import java.util.function.BiConsumer

fun myFunction(ctx: Ctx, payload: Payload): BiConsumer<Throwable?, Result?> {
    return BiConsumer { throwable, result ->
        extracted(ctx, payload, throwable, result)
    }
}

3. 避免误传递函数执行结果而非函数本身 #

检查调用whenComplete的代码，确保你传递的是myFunction返回的回调函数，而非直接执行回调的结果。比如不要写成：

// 错误：直接执行了回调函数，传递给whenComplete的是Unit类型
someFuture.whenComplete(myFunction(ctx, payload).invoke(null, null))

正确写法就是保持：

someFuture.whenComplete(myFunction(ctx, payload))

内容的提问来源于stack exchange，提问作者oligofren