The Complete Production SOP: How to Deploy and Run Kotlin Coroutines & Structured Concurrency Patterns in Autonomous AI Agents

---
name: "kotlinx-coroutines-structured-concurrency"
description: "Manage non-blocking asynchronous execution, cancellations, and flows using Kotlin coroutines."
metadata:
  author: "JetBrains"
  version: "1.0.0"
  runtime_compatibility:
    - "codex"
    - "claude-code"
    - "cursor"
    - "windsurf"
triggers:
  - "kotlin coroutines structured concurrency"
  - "supervisorscope kotlin"
  - "kotlin flow reactive stream"
permissions:
  fs_read: true
  fs_write: "workspace"
  shell_exec: false
  net_access: false
---

dependencies {
    implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core:1.8.0")
    testImplementation("org.jetbrains.kotlinx:kotlinx-coroutines-test:1.8.0")
}

kotlin {
    compilerOptions {
        freeCompilerArgs.add("-opt-in=kotlinx.coroutines.ExperimentalCoroutinesApi")
    }
}

package com.example.concurrency

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*

class AggregateService(
    private val ioDispatcher: CoroutineDispatcher = Dispatchers.IO
) {
    suspend fun fetchAggregatedTelemetry(userId: String): TelemetryResult = supervisorScope {
        val metricsDeferred = async(ioDispatcher) { fetchMetrics(userId) }
        val profileDeferred = async(ioDispatcher) { fetchProfile(userId) }

        val metrics = runCatching { metricsDeferred.await() }.getOrDefault(TelemetryMetrics.EMPTY)
        val profile = runCatching { profileDeferred.await() }.getOrNull()

        TelemetryResult(userId, metrics, profile)
    }

    fun streamEvents(userId: String): Flow<Event> = flow {
        while (currentCoroutineContext().isActive) {
            val event = pollNextEvent(userId)
            if (event != null) emit(event)
            delay(100L)
        }
    }.flowOn(ioDispatcher)

    private suspend fun fetchMetrics(id: String): TelemetryMetrics = withContext(ioDispatcher) { TelemetryMetrics.sample() }
    private suspend fun fetchProfile(id: String): ProfileData = withContext(ioDispatcher) { ProfileData.sample() }
    private fun pollNextEvent(id: String): Event? = Event.sample()
}