Kotlin协程协同取消解释
Kotlin协程是一种轻量级的并发编程框架，它通过协同取消来实现协程的取消操作。协同取消是指在协程执行过程中，通过发送取消信号来终止协程的执行。
Kotlin协程的协同取消机制基于协程的取消异常，即CancellationException。当一个协程被取消时，它会抛出CancellationException异常，从而中断协程的执行。开发者可以通过捕获CancellationException异常来处理协程的取消逻辑。
协同取消的优势在于它可以有效地管理协程的生命周期，避免资源泄漏和无效的计算。通过协同取消，开发者可以在需要取消协程时，及时释放协程所占用的资源，提高系统的性能和资源利用率。
Kotlin协程的协同取消可以应用于各种场景，例如网络请求、文件读写、定时任务等。在网络请求中，当用户取消了一个正在进行的网络请求时，可以使用协程的协同取消机制来中断请求的执行，避免浪费网络资源。在文件读写中，当用户关闭了一个正在进行的文件读写操作时，可以使用协程的协同取消机制来中断操作，避免资源的浪费和文件的损坏。
腾讯云提供了一系列与Kotlin协程相关的产品和服务，例如云函数SCF（Serverless Cloud Function）和云原生应用引擎TKE（Tencent Kubernetes Engine）。云函数SCF是一种无服务器计算服务，可以通过编写Kotlin协程来实现函数的并发执行和协同取消。云原生应用引擎TKE是一种容器化部署和管理服务，可以通过Kotlin协程来实现容器的并发管理和协同取消。
更多关于腾讯云产品和服务的信息，可以访问腾讯云官方网站：https://cloud.tencent.com/
相关·内容
2回答
在Kotlin中，coroutine取消是合作的。我该如何理解它呢？ Link to Kotlin documentation。
浏览 25提问于2019-05-18得票数 4
2回答
如果我们在main函数中使用协程，那么协程如何在延迟后恢复执行。就像在这个图像中，协程在主函数中，延迟2秒后代码恢复。所以我只想知道延迟后如何执行返回到代码。我知道状态机和android中的协程是如何工作的。我问的是kotlin的main函数(不是android activity )。
浏览 8提问于2021-09-15得票数 0
我正在尝试将HttpURLConnection与Kotlin协程一起使用，如下所示 var downloadJob: Job? = null
fun triggerDownload() {
job = downloadFile()
}
override fun onBackPressed() {
downloadJob.cancel()
super.onBackPressed()
}
fun downloadFile() = launch {
withContext(Dispatchers.IO) {
var connnection:
浏览 31提问于2021-03-31得票数 0
回答已采纳
我正在尝试实现开始同步过程，而应用程序出现在前台。
我想在后台线程中进行多个API调用，对于这种情况，Kotlin Coroutines和ThreadPool executor哪个更好？
我试过使用Kotlin Coroutines，但它似乎试图并行执行所有函数调用，这会导致应用程序初始时间的一些延迟。有没有并行执行多个函数的最佳方法？
浏览 4提问于2019-09-30得票数 1
与FlowCollector中的emit()函数不同，yield函数在取消协同例程时不协同工作。以下是示例程序：
import kotlinx.coroutines.flow.collect
import kotlinx.coroutines.flow.flow
import kotlinx.coroutines.runBlocking
import kotlinx.coroutines.withTimeoutOrNull
fun main(): Unit = runBlocking {
withTimeoutOrNull(5000) {
getFlow().coll
浏览 2提问于2021-06-10得票数 0
的CoroutineScope是什么
runBlocking {
// some code here
}
在Kotlin Coroutines？
当类被垃圾回收时，它是被调用的类的本地，并且协程被垃圾回收吗?如果它还在运行，它会导致内存泄漏吗？
浏览 4提问于2021-09-20得票数 1
当我有
@Test
fun test() {
val handler = CoroutineExceptionHandler { _, exception ->
println("CoroutineExceptionHandler got $exception")
}
GlobalScope.launch(handler) {
throw IllegalAccessException("Just testing")
}
浏览 3提问于2020-12-30得票数 2
1回答
我正在尝试在协程中运行一些长时间运行的任务。有时我需要取消这个协程，但在job.cancel()之后，它仍然可以继续工作。 下面是一些类似于我的真实代码的代码演示： class TestActivity : AppCompatActivity()
{
val job = Job()
override fun onCreate(savedInstanceState: Bundle?)
{
super.onCreate(savedInstanceState)
lifecycleScope.launch(Dispatchers.IO +
浏览 26提问于2020-12-09得票数 1
回答已采纳
当您开始学习Kotlin协程时，您看到的第一个示例之一是可以启动数十万个协程，但在尝试对线程执行相同的操作时会遇到OutOfMemory异常。
虽然这个例子很“酷”，但我不认为它对现实世界的Android应用程序开发有什么用处，甚至有点误导。当然，您可以启动数十万个只做delay()的协程，但在现实中，您要么启动执行某种IO或某种计算的协程。
例如，如果您启动了数十万个协程，并且每个协程都使用Retrofit执行一个网络请求，那么它不会比传统地使用没有协程的Retrofit更轻量级，因为okhttp仍然会为每个请求阻塞一个线程。
当您使用协程进行计算时，情况也是如此。那么它也不是更轻量级的，因
浏览 1提问于2020-05-07得票数 3
在codeLabs教程(Android - Kotlin - Room with a View)中，他们使用了"viewModelScope.launch(Dispatchers.IO)“来调用insert方法。它到底是什么，为什么要用它。请参考链接， https://codelabs.developers.google.com/codelabs/android-room-with-a-view-kotlin/#8 fun insert(word: Word) = viewModelScope.launch(Dispatchers.IO) {
repository.inser
浏览 1092提问于2019-05-04得票数 7
1回答
我将以下Kotlin代码部署为OpenShift中的容器： fun main(args: Array<String>): Unit = io.ktor.server.netty.EngineMain.main(args)
@kotlin.jvm.JvmOverloads
fun Application.module() {
launch { consumeProductionGeneratingUnits1hTopic() }
launch { consumeProductionLargeGeneratingUnits1hTopic() }
launc
浏览 32提问于2021-09-02得票数 1
回答已采纳
1回答
目前，在我的代码库中，使用Kotlin，我有一个扩展函数，它以如下方式工作。
async {
executeSomeCodeToGetResult()
}.awaitOnUiThread { result ->
useResultOnUiThread(result)
}
async函数将runnable加载到返回Future<T>结果的ExecutorService上。awaitOnUiThread是Future<T>对象上的一个扩展函数，它将T作为参数发送到输入函数。
我想知道是否有办法使用Kotlin coroutines来达到类似的结果？
我
浏览 23提问于2019-08-06得票数 2
回答已采纳
在Kotlin 1.3中，人们可以使用GlobalScope.launch启动作业，但有一件事我似乎搞不懂，那就是如何跟踪GlobalScope.launch`返回的Job，并取消所有处于活动状态的挂起作业。
在旧版本的launch中，可以指定parent = parentJob，也可以简单地取消parentJob。但是，当使用GlobalScope.launch时，如何(轻松地)取消所有挂起的作业，比如从ViewModel的onCleared中，可以取消所有挂起的内容。
浏览 1提问于2018-11-09得票数 0
2回答
Jetbrains在每一篇关于kotlin的文章中都谈到了异步编程。但我不明白为什么它们被称为异步？据我所知，kotlin协程--这是一个带有预初始化线程池的状态机。我们有一个工作线程池和一个io线程池。对我来说，这只是一个多线程编程。如果我们向协程发送阻塞代码，线程将被阻塞。如果我们使用async方法(来自默认协程库)，它会给我们一种异步工作的错觉，但这只是将“job”发送到另一个线程。
如果我们使用带有协程的async io，另一个问题。但这是IO API异步，而不是kotlin协程。与其他语言相比，Java没有很好的io异步api (可能是错误的)。据我所知，.NET已经重建了他们的异步
浏览 5提问于2021-09-17得票数 3
我应该在我的build.gradle文件中修改什么或者在类中导入什么才能在我的Android项目中使用Kotlin1.3中稳定的协程函数？
关于我的build.gradle中的协程的片段
implementation "org.jetbrains.kotlin:kotlin-coroutines-core:$coroutines_version" implementation "org.jetbrains.kotlin:kotlin-coroutines-android:$coroutines_version"
当然我用的是Android Studio 3.3
浏览 4提问于2018-10-25得票数 12
因此我有一个引用的空地图，如下所示：
private var labelsForGroupId: Map<GroupId, Label> = emptyMap()
通过网络api降低调用量。在第一次调用之后，我将响应缓存到映射。
但是，我希望将TTL添加到映射中(例如，每小时它都应该是空的)。我是Kotlin的新手，所以想知道这里的一些例子是什么最好的方法？
浏览 4提问于2021-08-27得票数 0
我使用来自的AutoClearedValue类，当视图被销毁时，支持字段变成null，这很好，但我有一个线程(实际上是一个kotlin协程)，在它完成之后，它访问值(它使用autoCleared)，但是如果在它的作业完成之前，我导航到另一个片段(这个片段的视图被销毁)，那么它试图访问这个值，但是因为它是null，所以我得到了一个异常，因此崩溃。对此我能做些什么呢？
另外，对于哪些变量需要使用此autoCleared？我将它用于viewBinding和recyclerview适配器。
浏览 2提问于2021-02-13得票数 5
我想把所有的AsyncTask重写成Kotlin Coroutines。在Java代码中调用并等待来自Coroutines的结果。例如:我在Kotlin中有一些耗时很长的方法。 Kotlin： class Coroutines {
suspend fun readFile(): String {
return GlobalScope.async {
read long file...
}.await()
}
} 现在，我想等待(但不阻塞UI线程) complete方法，理想情况下不需要回调。 Java： pub
浏览 8提问于2019-10-10得票数 2
我正在做一些kotlin协程的实验，特别是我想从polidea库中返回一个RxBleDevice到我的协程中。但是，Polidea scanBleDevices函数在订阅时返回Disposable。根据我的代码，有没有办法返回给我的协程一个RxBleDevice？ 这是我的代码，目前它不能编译： val scanDevices: Deferred<RxBleDevice> = GlobalScope.async {
rxBleClient.scanBleDevices(ScanSettings.Builder()
.bui
浏览 14提问于2019-01-16得票数 0
回答已采纳
1回答
Kotlin corutines对于有限状态机和一些任务运行器(例如，默认ForkJoinPool)来说是糖。
换句话说，java/kotlin运行时中还没有运行时协程(但这可能会随着的变化而改变)。Kotlin协程只是一个接一个地执行的任务的顺序。每个任务都可以在线程池中的任何线程中执行。
Go运行时支持“协程”。但是goroutines并不是真正的协程。Goroutines不允许在程序中设置屈服点。另外，Go不允许设置自定义线程池。您可以仅设置默认池中线程的大小。
kotlin协程和goroutines之间的第一个区别是Go运行时管理此时正在运行的协程。当goroutine在某些IO操作(
浏览 2提问于2017-10-21得票数 44
回答已采纳
1回答
我已经创建了一个自定义日志记录器，用于将我所有的日志写入文件和android日志。由于文件写入是一个阻塞操作，我现在希望使用Kotlin协程使文件写入异步。仅仅将写操作包装在协程中是行不通的，因为这样做会导致一些日志被调换，并且不会以正确的顺序写入文件。如何确保日志是按顺序写入的，同时不会阻塞主线程的文件操作，最好使用Kotlin协程？
浏览 22提问于2020-05-08得票数 3
回答已采纳
我正在尝试使用kotlin在应用程序中创建一个简单的加载屏幕 不只是显示文本，我想播放声音并显示图像，比如，3秒。 我使用Thread.sleep创建了一个设置为3秒的布局，但它不起作用。 有人能看到我错过了什么吗？ 谢谢! class MatrixActivity : AppCompatActivity() {
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.loading
浏览 25提问于2019-12-27得票数 0
2回答
我在kotlin的一个viewModel的初始化中启动了协程。协程侦听循环中的数据，一切正常，但作为标题sugguest，我无法取消该协程(或者也许viewmodel没有调用清除)，因为socked保持连接。 // viewmodel
init {
viewModelScope.launch {
connector()
}
}
override fun onCleared() {
viewModelScope.cancel()
super.onCleared()
}
suspend fun connector() = withContext
浏览 58提问于2019-09-02得票数 0
如何使用ThreadLocal Webdriver在kotest中并行执行浏览器？不知何故，我相信kotlin协程把事情搞砸了。
浏览 15提问于2021-08-23得票数 0
我对Kotlin协程和线程的理解是这样的： 一个线程一次只能运行一个协程。一个线程可以同时处理多个协程。它可以挂起一个协程并运行一个不同的协程。但是在给定的时间点上，一个线程上只有一个协程在运行。您不能在同一时间点在同一线程上运行多个协程。 是这样的吗？
浏览 81提问于2020-10-05得票数 1
回答已采纳
我想知道是否可以通过callbackFlow传递处理onClick的onClik，就像我在这篇文章中看到的那样。我很难实现，因为onClick Callback在参数里面，Button也是函数，所以不能实现扩展函数
不管怎样，我尝试了像这样的东西
lateinit var buttonListener :Flow<Unit>
fun <T >offers(t: T) = callbackFlow {
offer(t)
awaitClose { null }
}
CoroutineScope(IO).laun
浏览 5提问于2021-05-30得票数 0
回答已采纳
我在博客里看到了
launch(parentJob + CommonPool) {
// my suspending block
}
然后我们可以在最后取消作业，即parentJob.cancel()，因此launch的作业也将被取消。
但是，如果我像下面这样使用CoroutineScope启动它，我应该把我的parentJob放在哪里
CoroutineScope(Dispatchers.IO + parentJob).launch{
// ...
}
或
CoroutineScope(Dispatchers.IO).launch(parentJob) {
// ...
浏览 3提问于2020-05-05得票数 0
因此，我有一个简单的算法，它以这种方式遵循树结构： ? 每次它从一个节点移动到下一个节点时，它会将上一个节点的属性传播到下一个节点，依此类推，以模拟节点彼此之间的效果。 有时，一个节点可能连接到多个节点。 在我目前的实现中，算法在完成树的其余部分之前，会沿着每条拆分的路径一直走到最后： ? 这是次优的，因为所有其他分支都必须等待算法完成，这是大量时间的浪费，特别是当树非常大的时候。 理想情况下，我希望每个拆分都会产生一个新的线程，这样所有的路由都会被并行地探索。 我目前是Kotlin协程的新手，所以如果这看起来很愚蠢，请容忍我。 目前，我正在考虑使用Kotlin的协程(注意:
浏览 10提问于2019-10-03得票数 3
回答已采纳
2回答
带延迟的Kotlin协程单元测试
、、、、
我正在尝试对一个使用delay()的Kotlin协程进行单元测试。对于单元测试，我并不关心delay()，它只会减慢测试速度。我希望以某种方式运行测试，使其在调用delay()时不会真正延迟。
我尝试使用委托给CommonPool的自定义上下文运行协程：
class TestUiContext : CoroutineDispatcher(), Delay {
suspend override fun delay(time: Long, unit: TimeUnit) {
// I'd like it to call this
}
overrid
浏览 106提问于2017-11-08得票数 36
回答已采纳
1回答
我想在Unity中实现一个接一个地播放音乐。我尝试创建一个audioClip数组，并想逐个播放它们。我还尝试使用StartCoroutine来等待一首歌曲完成，然后播放下一首。 我尝试创建一个audioClip数组，并想逐个播放它们。我还尝试使用StartCoroutine来等待一首歌曲完成，然后播放下一首。 using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using UnityEngine.Audio;
[RequireComponent(typeof(AudioSource))
浏览 32提问于2019-05-24得票数 0
回答已采纳
我想知道如何在kotlin中将消息从一个线程发送到主线程。ps:不是在android上。我不想要任何android平台特定的答案。
我已经在android平台上尝试过了，如下所示
private val uiThreadHandler = object : Handler(Looper.getMainLooper()) {
override fun handleMessage(msg: Message) {
(msg.obj as () -> Unit)()
}
}
并将其用作
uiThreadHandler.obt
浏览 0提问于2019-01-18得票数 0
2回答
为了重申标题，我想知道是否有方法可以将下面的MyThread类转换为Kotlin Coroutine。 如果仔细观察，您会注意到MyThread类有一个名为someObject的属性变量，可以从run和cancel方法中对其进行修改。在这种情况下，SomeObject完全封装在MyThread中，我希望保持这种方式。有没有办法将MyThread转换成协程，或者我已经有了最优雅的代码版本？ class MyCancellable: Thread(){
val someObject= SomeObject()
override fun run() {
super
浏览 26提问于2021-09-14得票数 0
回答已采纳
我试着使用两个我想要在同一时间连续执行的例程，但只有第一个例程在运行…
我哪里错了？
async def screen(self): #first routine
Writer.set_textpos(ssd, 0, 0) # In case previous tests have altered it
wri = Writer(ssd, small, verbose=False)
wri.set_clip(False, False, False)
...
refresh(ssd)
utime.sleep_ms(200)
浏览 2提问于2020-08-08得票数 0
如何在进入或退出“挂起”函数时调试Kotlin代码？(请参见下面的示例)。
fun mainFunction() = runBlocking {
println("before suspend call")
anotherFunction()
println("after suspend call")
}
suspend fun anotherFunction() {
// do something
}
我知道Kotlin协同例程在执行挂起函数时做了很多神奇的事情，而且在那一刻执行可能会切换线程。因此，当我走出"a
浏览 3提问于2019-04-20得票数 41
1回答
我正在尝试在一个Android应用中使用Kotlin Coroutines，特别是我已经导入了。
Kotlin Coroutine更改Retrofit接口以返回Deferred<T>而不是Call<T>。
我不明白的是如何在我想要的特定CoroutineContext中启动这个Deferred。考虑以下代码：
class MyViewModel @Inject constructor(
private val foo: Foo,
@Named("ui") private val uiContext: Corouti
浏览 0提问于2018-08-10得票数 1
回答已采纳
2回答
显然有用于SqlDelight的Kotlin协程扩展函数，但我不知道如何实现它们，因为我找不到文档。
我有一个普通的查询，如下所示：
val allItems
get() = itemQueries.selectAll().mapToList()
我能把它变成一个挂起函数吗？
浏览 4提问于2020-02-23得票数 3
考虑这个不可取消的协程，正如它的名字所暗示的那样。 fun main(args: Array<String>) = runBlocking {
val nonCancellableJob = launch(Dispatchers.Default) {
for (i in 1..1000) {
if (i % 100 == 0) {
println("Non cancellable iteration $i")
}
}
}
pr
浏览 25提问于2020-12-10得票数 1
回答已采纳
1回答
我对Python和ECMAScript中的生成器的理解是，它们比普通生成器更强大。例如，它们都允许通过next()将值传递回生成器，并且都允许从另一个生成器(Python中的yield from和ES6中的yield * )生成，这是生成器中不需要的两件事。
那么，考虑到这种扩展的功能，在Python和ES6中实现的生成器是否与协程相同？有什么不同吗？
浏览 0提问于2015-08-08得票数 1
我正在开发安卓系统，我想使用HandlerThread来启动一个类似以下代码的countdownTimer。
private var bgHandlerThread: HandlerThread? = HandlerThread("MyHandlerThread")
private fun startTimer() {
bgHandlerThread = HandlerThread("MyHandlerThread")
bgHandlerThread!!.start()
val bgHandler = Ha
浏览 14提问于2019-08-21得票数 0
2回答
我已经尝试阅读了Kotlin协程的各种教程和页面，尽管它对我来说是有意义的，但我仍然没有感觉到它被点击了，我还没有准备好用协程编写异步非阻塞代码。我认为我缺少的是一张图表或图片，说明当一段协程代码执行时到底发生了什么，以及以什么顺序执行。这些代码是如何在线程级别运行的？
launch {
delay(1000)
println("World (${currentThread().name})")
}
println("Hello (${currentThread().name})")
sleep(1
浏览 1提问于2019-07-29得票数 8
我对Kotlin是个新手，来自C# it我很习惯Kotlin。
在返回频道列表之前，如何等待tvClient得到响应？
override fun getChannels(): MutableList<Channel> {
disposable = tvClient.getChannels()
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(
浏览 0提问于2018-10-24得票数 0
2回答
有很多关于架构组件、kotlin和协程的信息，但我找不到一个将所有这些东西结合在一起的示例。我正在苦苦思索如何结合使用和协程来使用安卓的架构组件。我有一个想法，但我不确定这是否是实现这种架构风格的正确方式。我尝试将视图模型+存储库模式与复古拟合和协程结合使用。
我有以下存储库：
class FooRepostiroy(private val fooHttpService: FooHttpService) {
suspend fun someMethod() : SomeResult {
val response = fooHttpService.someRemotCall(
浏览 1提问于2020-06-03得票数 0
1回答
我期望的结果是(0，1)或(0，1，2)，但打印的数字不断增加。我在学习关于协程的知识。我遵循了这个例子，但我对它很好奇，所以我写了代码，发现了一些奇怪的东西。 class test {
@Test
fun test() = runBlocking {
val startTime = System.currentTimeMillis()
val job = launch {
var nextTime = startTime
var i = 0
while (isActiv
浏览 21提问于2021-07-25得票数 0
2回答
我正在我当前的Android应用程序中试验Kotlin Coroutines。 我有一个用户可以使用远程RestFul应用程序接口搜索文本的用例。 我希望达到的目标如下： 1)。使用类型"ABC“，我在这个搜索字符串中启动了我的远程API viewModelScope.launch {
repository.searchAPI(searchString)
} 2)。用户现在键入更多内容，因此我的搜索字符串现在是"ABCXYZ“ 现在我希望取消对"ABC“的初始搜索，并将其替换为新的搜索字符串"ABCXYZ”。 我想我可以用这段代码。 viewModelSc
浏览 12提问于2019-10-08得票数 7
回答已采纳
我有一些代码在协程的函数调用中使用请求作用域的bean。看起来spring并不知道我还在同一个请求中。
有没有可能让spring理解我仍然想要请求作用域的bean，即使调用来自异步Kotlin协程？
当代码运行时，我收到以下错误消息：
org.springframework.beans.factory.BeanCreationException:
Error creating bean with name 'scopedTarget.wsContext':
Scope 'request' is not active for the current threa
浏览 1提问于2019-04-07得票数 5
我正在尝试编写一个单元测试，等待kotlin挂起函数的完成，然后再检查如下结果： @Test
fun shouldSetupThingsProperly() {
val context = InstrumentationRegistry.getInstrumentation().context
runBlocking { MyObject.enable(context, false) }
Assert.assertTrue( /* whatever usefull */ true)
} 暂停方法如下： object MyObject {
@JvmStatic
浏览 70提问于2020-04-08得票数 2
2回答
我可以通过存储库类中托管的retrofit.this代码从网络接收数据：
fun getQuestionsFromWebServer() {
val webService = AppModule()
val call = webService.provideModirfaniService().getQuestions()
call.enqueue(object : Callback<List<Question>> {
override fun onResponse(
call: Cal
浏览 5提问于2020-10-25得票数 0
我是Unity的新手，正在尝试通过我的脚本更新VideoPlayer。我已经确认代码正在与预设值一起工作，但当我运行videoPlayer.url = "new video url"时，它将不会播放。
这是我播放视频的代码。这将工作，但一旦我给它一个网址更新，它只是改变了来源，但不播放视频。
public IEnumerator playVideo(string videoYear) {
// This line updates the url but the video will not actually play.
videoPlayer.u
浏览 2提问于2019-08-22得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
