/* | |
* Copyright 2016-2018 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license. | |
*/ | |
package kotlinx.coroutines | |
import org.junit.* | |
class TestBaseTest : TestBase() { | |
@Test | |
fun testThreadsShutdown() { | |
repeat(1000 * stressTestMultiplier) { _ -> | |
initPoolsBeforeTest() | |
val threadsBefore = currentThreads() | |
runBlocking { | |
val sub = launch { | |
delay(10000000L) | |
} | |
sub.cancel() | |
sub.join() | |
} | |
shutdownPoolsAfterTest() | |
checkTestThreads(threadsBefore) | |
} | |
} | |
} |