jvm/test/UnconfinedConcurrentStressTest.kt

package kotlinx.coroutines

import kotlinx.coroutines.testing.*
import org.junit.*
import org.junit.Test
import java.util.concurrent.*
import kotlin.test.*

class UnconfinedConcurrentStressTest : TestBase() {
    private val threads = 4
    private val executor = newFixedThreadPoolContext(threads, "UnconfinedConcurrentStressTest")
    private val threadLocal = ThreadLocal<Int>()

    @After
    fun tearDown() {
        executor.close()
    }

    @Test
    fun testConcurrent() = runTest {
        val iterations = 1_000 * stressTestMultiplier
        val startBarrier = CyclicBarrier(threads + 1)
        val finishLatch = CountDownLatch(threads)

        repeat(threads) { id ->
            launch(executor) {
                startBarrier.await()
                repeat(iterations) {
                    threadLocal.set(0)
                    launch(Dispatchers.Unconfined) {
                        assertEquals(0, threadLocal.get())
                        launch(Dispatchers.Unconfined) {
                            assertEquals(id, threadLocal.get())
                        }

                        threadLocal.set(id)
                    }
                }

                finishLatch.countDown()
            }
        }

        startBarrier.await()
        finishLatch.await()
    }
}