Implement some tests for the new functionality

Author: dkhalanskyjb

integration/kotlinx-coroutines-guava/test/ListenableFutureTest.kt

@@ -9,6 +9,7 @@ import org.junit.Test
 import java.util.concurrent.*
 import java.util.concurrent.CancellationException
 import java.util.concurrent.atomic.*
+import kotlinx.coroutines.testing.CountDownLatch
 import kotlin.test.*
 
 class ListenableFutureTest : TestBase() {

kotlinx-coroutines-core/concurrent/test/DefaultDelayTest.kt

@@ -0,0 +1,17 @@
+package kotlinx.coroutines
+
+import kotlin.test.*
+import kotlinx.coroutines.testing.*
+
+class DefaultDelayTest: TestBase() {
+    @Test
+    fun testDelayOnUnconfined() = runTest {
+        val latch = CountDownLatch(1)
+        launch(Dispatchers.Unconfined) {
+            delay(1)
+            latch.await()
+        }
+        delay(10)
+        latch.countDown()
+    }
+}

kotlinx-coroutines-core/concurrent/test/RunBlockingTest.kt

@@ -100,7 +100,7 @@ class RunBlockingTest : TestBase() {
                 }
             }
             expectUnreached()
-        } catch (e: CancellationException) {
+        } catch (_: CancellationException) {
             finish(4)
         }
     }
@@ -195,6 +195,22 @@ class RunBlockingTest : TestBase() {
         }
     }
 
+    /** Tests that tasks scheduled on a closed `runBlocking` event loop get processed in an I/O thread. */
+    @OptIn(ExperimentalStdlibApi::class)
+    @Test
+    fun testLeakedEventLoopGetsProcessedInIO() {
+        val dispatcher = runBlocking {
+            coroutineContext[CoroutineDispatcher.Key]
+        }!!
+        runBlocking {
+            GlobalScope.launch(dispatcher) {
+                assertTrue(runningOnIoThread())
+                delay(1.milliseconds)
+                assertTrue(runningOnIoThread())
+            }.join()
+        }
+    }
+
     /** Will not compile if [runBlocking] doesn't have the "runs exactly once" contract. */
     @Test
     fun testContract() {
@@ -205,3 +221,5 @@ class RunBlockingTest : TestBase() {
         rb.hashCode() // unused
     }
 }
+
+internal expect fun runningOnIoThread(): Boolean

kotlinx-coroutines-core/jvm/test/ExecutorsTest.kt

@@ -2,9 +2,10 @@ package kotlinx.coroutines
 
 import kotlinx.coroutines.testing.*
 import org.junit.Test
-import java.util.concurrent.*
 import kotlin.coroutines.*
 import kotlin.test.*
+import java.util.concurrent.Executors
+import java.util.concurrent.RejectedExecutionException
 
 class ExecutorsTest : TestBase() {
     private fun checkThreadName(prefix: String) {
@@ -45,7 +46,7 @@ class ExecutorsTest : TestBase() {
 
     @Test
     fun testConvertedDispatcherToExecutor() {
-        val executor: ExecutorService = Executors.newSingleThreadExecutor { r -> Thread(r, "TestExecutor") }
+        val executor = Executors.newSingleThreadExecutor { r -> Thread(r, "TestExecutor") }
         val dispatcher: CoroutineDispatcher = executor.asCoroutineDispatcher()
         assertSame(executor, dispatcher.asExecutor())
         executor.shutdown()

kotlinx-coroutines-core/jvm/test/FailingCoroutinesMachineryTest.kt

@@ -5,9 +5,10 @@ import org.junit.*
 import org.junit.Test
 import org.junit.runner.*
 import org.junit.runners.*
-import java.util.concurrent.*
+import java.util.concurrent.Executors
 import kotlin.coroutines.*
 import kotlin.test.*
+import kotlin.time.Duration.Companion.seconds
 
 @RunWith(Parameterized::class)
 class FailingCoroutinesMachineryTest(
@@ -139,7 +140,7 @@ class FailingCoroutinesMachineryTest(
     }
 
     private fun checkException() {
-        latch.await(2, TimeUnit.SECONDS)
+        latch.await(2.seconds)
         val e = caught
         assertNotNull(e)
         // First condition -- failure in context element

kotlinx-coroutines-core/jvm/test/JobChildStressTest.kt

@@ -4,6 +4,7 @@ import kotlinx.coroutines.testing.*
 import java.util.concurrent.*
 import java.util.concurrent.atomic.*
 import kotlin.test.*
+import kotlinx.coroutines.testing.CountDownLatch
 
 /**
  * Testing the procedure of attaching a child to the parent job.

kotlinx-coroutines-core/jvm/test/ReusableCancellableContinuationInvariantStressTest.kt

@@ -2,7 +2,6 @@ package kotlinx.coroutines
 
 import kotlinx.coroutines.testing.*
 import org.junit.Test
-import java.util.concurrent.CountDownLatch
 import java.util.concurrent.atomic.AtomicReference
 import kotlin.coroutines.*
 

kotlinx-coroutines-core/jvm/test/RunBlockingJvmTest.kt

@@ -182,3 +182,5 @@ class RunBlockingJvmTest : TestBase() {
         return result.get().getOrThrow()
     }
 }
+
+internal actual fun runningOnIoThread(): Boolean = Thread.currentThread().isIoDispatcherThread()

kotlinx-coroutines-core/jvm/test/ThreadLocalStressTest.kt

@@ -2,7 +2,6 @@ package kotlinx.coroutines
 
 import kotlinx.coroutines.testing.*
 import kotlinx.coroutines.sync.*
-import java.util.concurrent.*
 import kotlin.coroutines.*
 import kotlin.coroutines.intrinsics.*
 import kotlin.test.*
@@ -139,7 +138,7 @@ class ThreadLocalStressTest : TestBase() {
                     cancel()
                     semaphore.acquire()
                 }
-            } catch (e: CancellationException) {
+            } catch (_: CancellationException) {
                 // Ignore cancellation
             }
         }
@@ -154,7 +153,7 @@ class ThreadLocalStressTest : TestBase() {
                     cancel()
                     semaphore.acquire()
                 }
-            } catch (e: CancellationException) {
+            } catch (_: CancellationException) {
                 // Ignore cancellation
             }
         }

kotlinx-coroutines-core/jvm/test/UnconfinedConcurrentStressTest.kt

@@ -4,6 +4,7 @@ import kotlinx.coroutines.testing.*
 import org.junit.*
 import org.junit.Test
 import java.util.concurrent.*
+import kotlinx.coroutines.testing.CountDownLatch
 import kotlin.test.*
 
 class UnconfinedConcurrentStressTest : TestBase() {