package kotlinx.coroutines

import kotlinx.coroutines.testing.*
import kotlinx.coroutines.channels.*
import kotlin.test.*


abstract class AbstractDispatcherConcurrencyTest : TestBase() {

   public abstract val dispatcher: CoroutineDispatcher

    @Test
    fun testLaunchAndJoin() = runTest {
        expect(1)
        var capturedMutableState = 0
        val job = GlobalScope.launch(dispatcher) {
            ++capturedMutableState
            expect(2)
        }
        runBlocking { job.join() }
        assertEquals(1, capturedMutableState)
        finish(3)
    }

    @Test
    fun testDispatcherHasOwnThreads() = runTest {
        val channel = Channel<Int>()
        GlobalScope.launch(dispatcher) {
            channel.send(42)
        }

        var result = ChannelResult.failure<Int>()
        while (!result.isSuccess) {
            result = channel.tryReceive()
            // Block the thread, wait
        }
        // Delivery was successful, let's check it
        assertEquals(42, result.getOrThrow())
    }

    @Test
    fun testDelayInDispatcher() = runTest {
        expect(1)
        val job = GlobalScope.launch(dispatcher) {
            expect(2)
            delay(100)
            expect(3)
        }
        runBlocking { job.join() }
        finish(4)
    }
}