core/kotlinx-coroutines-core/test/DefaultExecutorStressTest.kt

package kotlinx.coroutines.experimental

import org.junit.*
import java.util.concurrent.*
import kotlin.coroutines.experimental.*

class DefaultExecutorStressTest : TestBase() {

    @Test
    fun testDelay() = runTest {
        val iterations = 100_000 * stressTestMultiplier

        val ctx = DefaultExecutor + coroutineContext
        expect(1)
        var expected = 1
        repeat(iterations) {
            expect(++expected)
            val deferred = async(ctx) {
                expect(++expected)
                val largeArray = IntArray(10_000) { it }
                delay(Long.MAX_VALUE, TimeUnit.NANOSECONDS)
                println(largeArray) // consume to avoid DCE, actually unreachable
            }

            expect(++expected)
            yield()
            deferred.cancel()
            try {
                deferred.await()
            } catch (e: JobCancellationException) {
                expect(++expected)
            }
        }

        finish(2 + iterations * 4)
    }
}