具有 Kotlin 协程的函数是否可以等待完成并 return 到 Java class?
Is it possible for a function with a Kotlin coroutine to wait for completion and return to a Java class?
我正在开发基于 Java 的 Android 应用程序。我想开始使用 Kotlin 和协同程序在主线程之外进行与网络相关的工作,但是我 运行 遇到了一个问题,试图弄清楚如何成功处理某种情况。
我已经创建了一个带有网络功能的 Kotlin 文件,我打算在 Java class 中调用它(一个视图模型,此时需要保持写入 Java).我的想法是,我希望网络功能修改 return 一个列表返回给视图模型,然后允许视图模型继续。
fun performNetworking(
data: MutableList<Data>
): MutableList<Data> {
CoroutineScope(Dispatchers.IO).launch {
data.forEach {
// modify each element in the list
}
}
return data
}
目前,我从 Java 视图模型中这样调用它:
public void modifyData(List<Data> data) {
List<Data> modifiedData = NetworkingKt.performNetworking(data);
performMoreThings(modifiedData);
}
通过此实现,performMoreThings()
触发就像列表中数据的 none 被修改一样。通过调试,我发现在coroutine scope可以做任何事情之前,performMoreThings()
的结论是用未修改的Data列表
因此,我想知道是否有一种方法可以让代码在 return 将数据列表 Java 视图模型 Java 之前等待协程范围的工作完成(不锁定主线程并阻止用户与应用程序交互)?还是我误解了协程的能力、目的和实现,这是不可能的?我是否必须传递对视图模型的引用并让它在协程完成后调用延续方法,就像我在其 onPostExecute()
?
中使用 AsyncTask 所做的那样
不,这是不可能的。不是因为协程的限制,而是相反——由于非协程代码的限制。你的 modifyData()
是一个常规的、不可暂停的方法,所以它不能在不阻塞线程的情况下等待。 Kotlin 的暂停函数可以做到这一点,但是 Java 方法不能。
您需要从后台线程调用 modifyData()
,这样阻塞不会成为问题,或者重新设计 performNetworking()
以使用处理异步任务的经典技术之一,即接收一个回调或 return 未来:
fun performNetworking(
data: MutableList<Data>
): CompletableFuture<MutableList<Data>> {
return CoroutineScope(Dispatchers.IO).future {
data.forEach {
// modify each element in the list
}
data
}
}
public void modifyData(List<Data> data) {
NetworkingKt.performNetworking(data)
.thenAccept(this::performMoreThings);
}
我正在开发基于 Java 的 Android 应用程序。我想开始使用 Kotlin 和协同程序在主线程之外进行与网络相关的工作,但是我 运行 遇到了一个问题,试图弄清楚如何成功处理某种情况。
我已经创建了一个带有网络功能的 Kotlin 文件,我打算在 Java class 中调用它(一个视图模型,此时需要保持写入 Java).我的想法是,我希望网络功能修改 return 一个列表返回给视图模型,然后允许视图模型继续。
fun performNetworking(
data: MutableList<Data>
): MutableList<Data> {
CoroutineScope(Dispatchers.IO).launch {
data.forEach {
// modify each element in the list
}
}
return data
}
目前,我从 Java 视图模型中这样调用它:
public void modifyData(List<Data> data) {
List<Data> modifiedData = NetworkingKt.performNetworking(data);
performMoreThings(modifiedData);
}
通过此实现,performMoreThings()
触发就像列表中数据的 none 被修改一样。通过调试,我发现在coroutine scope可以做任何事情之前,performMoreThings()
的结论是用未修改的Data列表
因此,我想知道是否有一种方法可以让代码在 return 将数据列表 Java 视图模型 Java 之前等待协程范围的工作完成(不锁定主线程并阻止用户与应用程序交互)?还是我误解了协程的能力、目的和实现,这是不可能的?我是否必须传递对视图模型的引用并让它在协程完成后调用延续方法,就像我在其 onPostExecute()
?
不,这是不可能的。不是因为协程的限制,而是相反——由于非协程代码的限制。你的 modifyData()
是一个常规的、不可暂停的方法,所以它不能在不阻塞线程的情况下等待。 Kotlin 的暂停函数可以做到这一点,但是 Java 方法不能。
您需要从后台线程调用 modifyData()
,这样阻塞不会成为问题,或者重新设计 performNetworking()
以使用处理异步任务的经典技术之一,即接收一个回调或 return 未来:
fun performNetworking(
data: MutableList<Data>
): CompletableFuture<MutableList<Data>> {
return CoroutineScope(Dispatchers.IO).future {
data.forEach {
// modify each element in the list
}
data
}
}
public void modifyData(List<Data> data) {
NetworkingKt.performNetworking(data)
.thenAccept(this::performMoreThings);
}