I just found out that this is the cause of the pro...

# coroutines

[Reisishot]

I just found out that this is the cause of the problem: (this being a Map)

keys.forEach { priority ->
            get(priority)?.forEachLimitedParallel(callable)
                ?: throw IllegalStateException("No list found for priority $priority")
        }

[Dico]

Replace runBlocking with coroutineScope and make your for each function suspend

[Dico]

Then, invoke the for each function from the scope you want it to use (and remove parameter from launch)

[Dico]

Alternatively, create worker coroutines that take items from a channel

[Reisishot]

@Dico I added the parameter to launch in orderr to limit my parallelity

[Reisishot]

Do you have any idea on how to achive this?

[Reisishot]

With unlimited paralelism I will run out of memory

[Reisishot]

Removing the parameter from launch worked BTW...

[Reisishot]

@Dico Thank you, works now 😄

[Dico]

You should have the dispatcher you made in the coroutine context when you call the function.