Annulation coopérative : isActive et ensureActive
Rendez les coroutines annulables en vérifiant isActive et en appelant ensureActive.
Annulation coopérative : isActive et ensureActive est une leçon Kotlin Academy gratuite sur CoddyKit. Ceci est la leçon 1 sur 4. Tu peux lire la leçon complète ci-dessous gratuitement — puis la pratiquer en direct dans le navigateur avec un éditeur de code intégré et un tuteur IA 24/7. Elle fait partie du parcours d'apprentissage Kotlin Academy, et ta progression se synchronise sur le web et l'application CoddyKit. Le cours Kotlin Academy comprend 4 leçons au total.
Pourquoi une annulation coopérative ?
Les coroutines Kotlin utilisent l’annulation coopérative : une coroutine annulée ne s’arrête que lorsqu’elle coopère en vérifiant son état d’annulation. Une boucle serrée utilisant le CPU ne s’arrêtera pas tant qu’elle n’effectuera pas cette vérification.
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")
}Vérifier isActive
isActive est une propriété de CoroutineScope qui retourne false dès qu’une annulation est demandée. La vérifier dans une boucle permet à la coroutine de coopérer.
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() lève une CancellationException si la coroutine est annulée. Il s’agit d’un remplacement direct de 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() comme point de coopération
yield() suspend brièvement la coroutine, ce qui permet à l’ordonnanceur de vérifier l’annulation et d’exécuter d’autres coroutines.
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 ou ensureActive
Utilisez isActive pour la logique conditionnelle (par exemple, sortir élégamment d’une boucle). Utilisez ensureActive() lorsque vous souhaitez propager immédiatement l’annulation sous forme d’exception.
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 est particulière
CancellationException n'est pas propagée au parent — elle signale une annulation normale. Ne l'absorbez jamais ; relancez-la toujours ou laissez-la se propager.
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}")
}Annulation d'un travail gourmand en CPU
Pour les travaux gourmands en CPU, insérez ensureActive() ou yield() à des points de contrôle naturels afin de permettre une annulation rapide.
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 dans une fonction de suspension personnalisée
Vous pouvez accéder à isActive dans n'importe quelle fonction de suspension via coroutineContext.isActive ou en utilisant 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()
}Annulation avec nettoyage des ressources
Même avec une annulation coopérative, les ressources peuvent être nettoyées dans des blocs finally — l'exception d'annulation continue de se propager à travers ceux-ci.
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()
}Interrogation périodique avec isActive
Les boucles d'interrogation périodique conviennent parfaitement à isActive : continuez à interroger jusqu'à l'annulation de la coroutine.
import kotlinx.coroutines.*
fun main() = runBlocking {
val job = launch {
while (isActive) {
println("Polling...")
delay(100)
}
println("Poller stopped")
}
delay(350)
job.cancel()
job.join()
}Différence avec Thread.interrupted()
Contrairement aux threads Java, les coroutines Kotlin ne reposent pas sur des indicateurs d'interruption. L'annulation est modélisée au moyen d'exceptions et de l'état de la portée, ce qui permet de la composer et de la structurer.
import kotlinx.coroutines.*
fun main() = runBlocking {
// Kotlin way: cooperative via isActive / ensureActive
launch {
ensureActive()
println("Kotlin coroutine: cancellation is explicit and structured")
}
}Vérification rapide
Quelle fonction lève immédiatement une exception lorsqu'une coroutine est annulée ?
Récapitulatif
L'annulation coopérative nécessite des points de contrôle explicites : isActive pour quitter conditionnellement, ensureActive() pour lever immédiatement une exception, céder() pour suspendre l'exécution et libérer le fil d'exécution. N'absorbez jamais CancellationException.
Questions Fréquemment Posées
La leçon « Annulation coopérative : isActive et ensureActive » est-elle gratuite ?
Oui — le texte complet de « Annulation coopérative : isActive et ensureActive » est gratuit à lire ici sur le web. Pour la pratiquer de manière interactive (un éditeur de code intégré et un tuteur IA 24/7) et déverrouiller le reste du cours Kotlin Academy, passe à CoddyKit PRO. Le cours Kotlin Academy comprend 4 leçons au total.
Qu'est-ce que j'apprendrai dans « Annulation coopérative : isActive et ensureActive » ?
Rendez les coroutines annulables en vérifiant isActive et en appelant ensureActive. Tu pratiques Kotlin Academy avec du code pratique que tu exécutes directement dans le navigateur, et un tuteur IA 24/7 répond à tes questions au fur et à mesure que tu avances dans la leçon.
Dois-je avoir de l'expérience pour commencer Kotlin Academy ?
Aucune expérience préalable n'est requise. Kotlin Academy sur CoddyKit est structuré pour les débutants jusqu'aux apprenants avancés, donc tu peux commencer ici ou depuis le début et avancer à ton rythme. Ceci est la leçon 1 sur 4.
Combien de temps prend la leçon « Annulation coopérative : isActive et ensureActive » ?
La plupart des leçons CoddyKit prennent environ 5–10 minutes. Chacune est courte et interactive, tu progresses régulièrement et tu repiques exactement où tu t'es arrêté sur le web et l'app.
Peux-tu écrire et exécuter du code dans cette leçon Kotlin Academy ?
Oui. Chaque leçon Kotlin Academy inclut un éditeur de code intégré, tu écris et exécutes du vrai code directement dans ton navigateur et tu reçois des retours IA instantanés — aucune configuration locale requise.
Toutes les leçons de ce cours
- Annulation coopérative : isActive et ensureActive
- withTimeout et withTimeoutOrNull
- Nettoyage avec finally et NonCancellable
- Propagation de l’annulation dans les hiérarchies de coroutines