IO: Use TestBase in all tests and fix leaking threads in tests

Author: elizarov

core/kotlinx-coroutines-io/src/test/kotlin/kotlinx/coroutines/experimental/io/ContentByteBufferTest.kt

@@ -1,13 +1,13 @@
 package kotlinx.coroutines.experimental.io
 
-import kotlinx.coroutines.experimental.runBlocking
+import kotlinx.coroutines.experimental.*
 import org.junit.Test
 import java.util.*
 import kotlin.test.assertEquals
 import kotlin.test.assertFalse
 import kotlin.test.assertTrue
 
-class ContentByteBufferTest {
+class ContentByteBufferTest : TestBase() {
     @Test
     fun testEmptyContent() = runBlocking {
         val ch = ByteReadChannel(ByteArray(0))

core/kotlinx-coroutines-io/src/test/kotlin/kotlinx/coroutines/experimental/io/JavaIOTest.kt

@@ -8,7 +8,7 @@ import java.io.*
 import java.nio.channels.*
 import kotlin.test.*
 
-class JavaIOTest {
+class JavaIOTest : TestBase() {
     private val channel = ByteChannel()
 
     @Test
@@ -177,6 +177,8 @@ class JavaIOTest {
         for (i in 1..numberOfLines) {
             assertEquals("OK $i", channel2.readUTF8Line())
         }
+
+        exec.close()
     }
 
     @Test
@@ -203,5 +205,6 @@ class JavaIOTest {
 
         pipe.source().close()
         pipe.sink().close()
+        exec.close()
     }
 }

core/kotlinx-coroutines-io/src/test/kotlin/kotlinx/coroutines/experimental/io/PooledBufferTest.kt

@@ -1,7 +1,7 @@
 package kotlinx.coroutines.experimental.io
 
+import kotlinx.coroutines.experimental.*
 import kotlinx.coroutines.experimental.io.internal.ReadWriteBufferState
-import kotlinx.coroutines.experimental.runBlocking
 import kotlinx.io.pool.*
 import org.junit.After
 import org.junit.Test
@@ -12,7 +12,7 @@ import kotlin.test.assertEquals
 import kotlin.test.assertTrue
 import kotlin.test.fail
 
-class PooledBufferTest {
+class PooledBufferTest : TestBase() {
     private val allocated = CopyOnWriteArrayList<ByteBuffer>()
 
     private inner class TestPool : ObjectPool<ReadWriteBufferState.Initial> {

core/kotlinx-coroutines-io/src/test/kotlin/kotlinx/coroutines/experimental/io/StateMachineChecker.kt

@@ -1,9 +1,10 @@
 package kotlinx.coroutines.experimental.io
 
+import kotlinx.coroutines.experimental.*
 import org.objectweb.asm.*
 import java.io.*
 
-class StateMachineChecker {
+class StateMachineChecker : TestBase() {
     private interface Filter {
         fun nonSuspend(className: String, methodName: String): Boolean
         fun suspend(className: String, methodName: String, hasStateMachine: Boolean): Boolean

core/kotlinx-coroutines-io/src/test/kotlin/kotlinx/coroutines/experimental/io/StringsTest.kt

@@ -11,7 +11,7 @@ import kotlin.test.assertNotEquals
 import kotlin.test.assertNull
 import kotlin.test.fail
 
-class StringsTest {
+class StringsTest : TestBase() {
     @get:Rule
     val timeout = Timeout(10, TimeUnit.SECONDS)