~improve tests

Kotlin · Mar 30, 2022 · 3ddac07 · 3ddac07
1 parent 7048a1a
commit 3ddac07
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 17 deletions.
diff --git a/...est/LimitedParallelismSharedStressTest.kt → .../test/LimitedParallelismConcurrentTest.kt b/...est/LimitedParallelismSharedStressTest.kt → .../test/LimitedParallelismConcurrentTest.kt
@@ -7,7 +7,7 @@ import kotlinx.coroutines.*
 import kotlinx.coroutines.exceptions.*
 import kotlin.test.*
 
-class LimitedParallelismSharedStressTest : TestBase() {
+class LimitedParallelismConcurrentTest : TestBase() {
 
     private val targetParallelism = 4
     private val iterations = 100_000
@@ -41,4 +41,19 @@ class LimitedParallelismSharedStressTest : TestBase() {
             }
         }
     }
+
+    @Test
+    fun testTaskFairness() = runTest {
+        val executor = newSingleThreadContext("test")
+        val view = executor.limitedParallelism(1)
+        val view2 = executor.limitedParallelism(1)
+        val j1 = launch(view) {
+            while (true) {
+                yield()
+            }
+        }
+        val j2 = launch(view2) { j1.cancel() }
+        joinAll(j1, j2)
+        executor.close()
+    }
 }
diff --git a/...s-core/jvm/test/LimitedParallelismTest.kt → ...mitedParallelismUnhandledExceptionTest.kt b/...s-core/jvm/test/LimitedParallelismTest.kt → ...mitedParallelismUnhandledExceptionTest.kt
@@ -9,22 +9,7 @@ import java.util.concurrent.*
 import kotlin.coroutines.*
 import kotlin.test.*
 
-class LimitedParallelismTest : TestBase() {
-
-    @Test
-    fun testTaskFairness() = runTest {
-        val executor = newSingleThreadContext("test")
-        val view = executor.limitedParallelism(1)
-        val view2 = executor.limitedParallelism(1)
-        val j1 = launch(view) {
-            while (true) {
-                yield()
-            }
-        }
-        val j2 = launch(view2) { j1.cancel() }
-        joinAll(j1, j2)
-        executor.close()
-    }
+class LimitedParallelismUnhandledExceptionTest : TestBase() {
 
     @Test
     fun testUnhandledException() = runTest {