What is the best approach of starting a long runni...

# coroutines

[svenjacobs]

What is the best approach of starting a long running computation inside a CoroutineScope that keeps on running even if the scope is cancelled and if another (new) scope is accessing the same function/computation, the already computed value should be returned? Sounds like a job for a ConflatedChannel, right? I tried something with Deferred but the code (test code!!) is far from beautiful:

var result: Deferred<Int>? = null

fun longComputationAsync(): Deferred<Int> {
    result = result ?: GlobalScope.async {
        println("longComputation")
        delay(1000)
        1337
    }
    return result!!
}

val scope1 = CoroutineScope(Dispatchers.Default)
scope1.launch {
    println("scope 1")
    println(longComputationAsync().await())
}
scope1.cancel()

val scope2 = CoroutineScope(Dispatchers.Default)
val job = scope2.launch {
    println("scope 2")
    println(longComputationAsync().await())
}

runBlocking {
    job.join()
}

[Matej Drobnič]

You don't need the channel

[Matej Drobnič]

If you just return one value, Deferred will be enough

[Matej Drobnič]

However in your case, you are creating longComputationAsync twice

[Matej Drobnič]

so two coroutines do not share same computation

[svenjacobs]

I'm storing result in the outer scope so that Deferred should be shared, right? This is just a simulation of a singleton object which might do the computation.

[bohsen]

Something like this: https://stackoverflow.com/questions/60155439/make-part-of-coroutine-continue-past-cancellation

[svenjacobs]

This is an interesting question but the NonCancellable solution for instance is not what I actually need. Using NonCancellable would mean that the computation is finished in scope1 however in my use case the result should land in scope2

[uli]

import kotlinx.coroutines.*

val result by lazy { longComputationAsync() }

fun longComputationAsync(): Deferred<Int> {
    return GlobalScope.async {
        println("longComputation")
        delay(1000)
        1337
    }
}

val scope1 = CoroutineScope(Dispatchers.Default)
scope1.launch {
    println("scope 1")
    println(result.await())
}
scope1.cancel()

val scope2 = CoroutineScope(Dispatchers.Default)
val job = scope2.launch {
    println("scope 2")
    println(result.await())
}

runBlocking {
    job.join()
}