Kooperativ annullering: isActive og ensureActive
Gør coroutines annullerbare ved at kontrollere isActive og kalde ensureActive.
Kooperativ annullering: isActive og ensureActive er en gratis Kotlin Academy-lektion på CoddyKit. Dette er lektion 1 af 4. Du kan læse alle 3 lektioner i dette læringsspor gratis i deres fulde længde — derefter låser CoddyKit PRO alle lektioner op samt praktiske øvelser med en indbygget kodeeditor og en AI-underviser døgnet rundt. Den er en del af læringsforløbet i Kotlin Academy, og dine fremskridt synkroniseres på tværs af nettet og CoddyKit-appen. Kotlin Academy-kurset indeholder 4 lektioner i alt.
Hvorfor samarbejdende annullering?
Kotlin-coroutiner bruger samarbejdende annullering: En annulleret coroutine stoppes kun, når den samarbejder ved at kontrollere sin annulleringstilstand. En tæt CPU-løkke stopper ikke, før den udfører denne kontrol.
import kotlinx.coroutines.*
fun main() = runBlocking {
val job = launch {
var i = 0
while (true) { i++ } // never checks — never cancels!
}
delay(100)
job.cancel()
println("cancel sent but loop kept running until process ended")
}Kontrol af isActive
isActive er en egenskab på CoroutineScope, der returnerer false, når der er anmodet om annullering. Hvis du kontrollerer den i en løkke, samarbejder coroutinen.
import kotlinx.coroutines.*
fun main() = runBlocking {
val job = launch {
var i = 0
while (isActive) {
i++
}
println("Loop exited after $i iterations")
}
delay(10)
job.cancel()
job.join()
}ensureActive()
ensureActive() kaster CancellationException, hvis coroutinen er annulleret. Det er en direkte erstatning for if (!isActive) throw CancellationException().
import kotlinx.coroutines.*
fun main() = runBlocking {
val job = launch {
try {
repeat(1_000_000) {
ensureActive() // throws if cancelled
// heavy computation here
}
} catch (e: CancellationException) {
println("Cancelled at iteration")
throw e
}
}
delay(5)
job.cancel()
job.join()
}yield() som samarbejdspunkt
yield() suspenderer coroutinen kortvarigt, så planlæggeren kan kontrollere annulleringen og køre andre coroutiner.
import kotlinx.coroutines.*
fun main() = runBlocking {
val job = launch {
repeat(10) { i ->
yield() // cooperative cancellation point + gives up scheduler
println("Step $i")
}
}
delay(2)
job.cancel()
job.join()
println("Done")
}isActive kontra ensureActive
Brug isActive til betinget logik (f.eks. til at komme yndefuldt ud af en løkke). Brug ensureActive(), når du vil videreføre annulleringen som en undtagelse med det samme.
import kotlinx.coroutines.*
fun main() = runBlocking {
launch {
repeat(100) { i ->
if (!isActive) {
println("Stopping at $i, cleaning up...")
return@launch
}
// work
}
}.also { delay(5); it.cancel(); it.join() }
}CancellationException er særlig
CancellationException forplanter sig ikke til forælderen — den signalerer normal annullering. Undertryk den aldrig; kast den altid igen, eller lad den forplante sig.
import kotlinx.coroutines.*
fun main() = runBlocking {
val job = launch {
try {
delay(1000)
} catch (e: CancellationException) {
println("Caught cancellation, rethrowing")
throw e // important!
}
}
delay(50)
job.cancel()
job.join()
println("Job state: ${job.isCancelled}")
}Annullering i CPU-bundet arbejde
Ved CPU-bundet arbejde skal du indsætte ensureActive() eller yield() ved naturlige kontrolpunkter, så annullering kan ske rettidigt.
import kotlinx.coroutines.*
suspend fun heavyCompute(n: Int): Long {
var result = 0L
for (i in 0..n) {
ensureActive()
result += i
}
return result
}
fun main() = runBlocking {
val job = launch(Dispatchers.Default) {
println(heavyCompute(1_000_000))
}
delay(10)
job.cancel()
job.join()
}isActive i en brugerdefineret suspend-funktion
Du kan få adgang til isActive i enhver suspend-funktion via coroutineContext.isActive eller ved at bruge currentCoroutineContext().isActive.
import kotlinx.coroutines.*
suspend fun checkable() {
while (currentCoroutineContext().isActive) {
delay(10)
println("tick")
}
}
fun main() = runBlocking {
val job = launch { checkable() }
delay(35)
job.cancel()
job.join()
}Annullering med oprydning af ressourcer
Selv ved kooperativ annullering kan ressourcer ryddes op i finally-blokke — annulleringsundtagelsen forplanter sig stadig gennem dem.
import kotlinx.coroutines.*
fun main() = runBlocking {
val job = launch {
try {
repeat(100) { i ->
ensureActive()
delay(20)
println("Working $i")
}
} finally {
println("Cleanup done")
}
}
delay(50)
job.cancel()
job.join()
}Gentagen kontrol med isActive
Løkker med gentagne tjek passer perfekt til isActive: fortsæt med at tjekke, indtil coroutinen annulleres.
import kotlinx.coroutines.*
fun main() = runBlocking {
val job = launch {
while (isActive) {
println("Polling...")
delay(100)
}
println("Poller stopped")
}
delay(350)
job.cancel()
job.join()
}Forskel fra Thread.interrupted()
I modsætning til Java-tråde er Kotlin-coroutiner ikke afhængige af afbrydelsesflag. Annullering modelleres via undtagelser og tilstanden i coroutine-området, hvilket gør den sammensættelig og struktureret.
import kotlinx.coroutines.*
fun main() = runBlocking {
// Kotlin way: cooperative via isActive / ensureActive
launch {
ensureActive()
println("Kotlin coroutine: cancellation is explicit and structured")
}
}Hurtigt tjek
Hvilken funktion kaster straks, når en coroutine annulleres?
Opsummering
Kooperativ annullering kræver eksplicitte kontrolpunkter: isActive til betinget afslutning, ensureActive() til at kaste straks og yield() til at suspendere og frigive tråden. Undertryk aldrig CancellationException.
Lær Kotlin med en AI-underviser — gratis
Skriv og kør rigtig kode i din browser, få øjeblikkelig hjælp fra en AI-underviser døgnet rundt, og fortsæt, hvor du slap, på web eller i appen.
- Kurser
- 51
- Lektioner
- 203
Ofte stillede spørgsmål
Er lektionen “Kooperativ annullering: isActive og ensureActive” gratis?
Ja — alle 3 lektioner i læringssporet Kotlin Academy, inklusive “Kooperativ annullering: isActive og ensureActive”, kan læses gratis i deres fulde længde her på webstedet. Derefter låser CoddyKit PRO alle lektioner op samt interaktive øvelser med en indbygget kodeeditor og en AI-underviser døgnet rundt. Kotlin Academy-kurset indeholder 4 lektioner i alt.
Hvad lærer jeg i “Kooperativ annullering: isActive og ensureActive”?
Gør coroutines annullerbare ved at kontrollere isActive og kalde ensureActive. Du øver dig i Kotlin Academy med praktisk kode, som du kører direkte i browseren, og en AI-vejleder døgnet rundt besvarer dine spørgsmål, mens du arbejder dig gennem lektionen.
Skal jeg have erfaring for at begynde på Kotlin Academy?
Der kræves ingen tidligere erfaring. Kotlin Academy på CoddyKit er tilrettelagt for både begyndere og øvede, så du kan starte her eller fra begyndelsen og lære i dit eget tempo. Dette er lektion 1 af 4.
Hvor lang tid tager lektionen “Kooperativ annullering: isActive og ensureActive”?
De fleste CoddyKit-lektioner tager cirka 5–10 minutter. Hver lektion er kort og interaktiv, så du gør løbende fremskridt og kan fortsætte, hvor du slap – på både web og app.
Kan jeg skrive og køre kode i denne Kotlin Academy-lektion?
Ja. Alle Kotlin Academy-lektioner har en indbygget kodeeditor, så du kan skrive og køre rigtig kode direkte i din browser og få øjeblikkelig feedback fra AI – uden lokal opsætning.
Alle lektioner i dette kursus
- Kooperativ annullering: isActive og ensureActive
- withTimeout og withTimeoutOrNull
- Oprydning med finally og NonCancellable
- Annulleringsformidling i coroutine-hierarkier