如何从Java 7调用Kotlin挂起协程函数

Question

我正在尝试从 Java 7 调用科特林函数。我正在使用协程，这个被调用的函数正在挂起，例如：

suspend fun suspendingFunction(): Boolean {
    return async { longRunningFunction() }.await()
}

suspend fun longRunningFunction() : Boolean {
    delay(400)
    return true
}

我在版本 0.25.3 中使用了协程，我可以通过传递继续来模拟简单的 Java 回调样式

CoroutinesKt.suspendingFunction(new Continuation<Boolean>() {
    @Override
    public CoroutineContext getContext() {
        return EmptyCoroutineContext.INSTANCE;
    }

    @Override
    public void resume(Boolean value) {
        doSomethingWithResult(value);
    }

    @Override
    public void resumeWithException(@NotNull Throwable throwable) {
        handleException(throwable);
    }
});

但是，在更新到完全稳定的1.0.1版本之后，我认为这不再可能。假设暂停函数的更新版本如下所示：

suspend fun suspendingFunction(): Boolean {
    return GlobalScope.async { longRunningFunction() }.await()
}

＜代码＞续

我知道通常建议将coroutine转换为< code>CompletableFuture，但是我使用的是Android，这意味着只使用Java 7。另一方面，简单的< code>Future太愚蠢了，因为我不想定期检查函数是否完成——我只想在函数完成时被调用。我真的希望避免添加新的库或许多额外的类/方法。

有没有简单的方法可以直接从Java7调用挂起函数？

由于静态编程语言试图与Java非常可互操作，我想会有一些简单的方法来做到这一点，但我还没有找到。

Answer 1

可以使用BuildersKt。这已经包含在< code >实现" org . jetbrains . kot linx:kot linx-coroutines-core:1 . 5 . 0 " 中

    BuildersKt.launch(
            GlobalScope.INSTANCE,
            (CoroutineContext) Dispatchers.getMain(),
            CoroutineStart.DEFAULT,
            (Function2<CoroutineScope, Continuation<? super Unit>, Unit>) (coroutineScope, continuation) -> {
                // your code here
                return Unit.INSTANCE;
            }
    );

Answer 2

根据您的环境，您有多个选项。

< li >如果在项目中使用< code>rxJava2，模块< code > kot linx-coroutines-rx2 具有在coro utines和Rx数据类型之间来回转换的实用函数。

实例

suspend fun sayHello(): String {
    delay(1000)
    return "Hi there"
}

fun sayHelloSingle(): Single<String> = GlobalScope.rxSingle { sayHello() }

示例（科特林一侧）

abstract class Continuation<in T> : kotlin.coroutines.Continuation<T> {
    abstract fun resume(value: T)
    abstract fun resumeWithException(exception: Throwable)
    override fun resumeWith(result: Result<T>) = result.fold(::resume, ::resumeWithException)
}   

示例（Java侧）

sayHello(new Continuation<String>() {
    @Override
    public CoroutineContext getContext() {
        return EmptyCoroutineContext.INSTANCE;
    }

    @Override
    public void resume(String value) {
        doSomethingWithResult(value);
    }

    @Override
    public void resumeWithException(@NotNull Throwable throwable) {
        doSomethingWithError(throwable);
    }
});