kotlin_coroutines.kt

kotlin_coroutines.kt

package com.kunalchhabra

import kotlinx.coroutines.*

fun main() = runBlocking {
    val startTime = System.currentTimeMillis()

    // Launch a new coroutine in background and continue
    val result1 = async { fetchDataFromSource1() }
    val result2 = async { fetchDataFromSource2() }

    // Wait for all the coroutines to complete and get the results
    val combinedResult = result1.await() + result2.await()

    val endTime = System.currentTimeMillis()
    println("Combined Result: $combinedResult")
    println("Time taken: ${endTime - startTime} ms")
}

suspend fun fetchDataFromSource1(): Int {
    delay(1000L)  // Simulate a long-running task
    println("Fetched data from source 1")
    return 10
}

suspend fun fetchDataFromSource2(): Int {
    delay(1500L)  // Simulate a long-running task
    println("Fetched data from source 2")
    return 20
}