Fix a flaky test (#4227)

Kotlin · Sep 23, 2024 · eac92c0 · eac92c0
1 parent cf4fcd1
commit eac92c0
Showing 1 changed file with 8 additions and 4 deletions.
diff --git a/kotlinx-coroutines-core/jvm/test/JobChildStressTest.kt b/kotlinx-coroutines-core/jvm/test/JobChildStressTest.kt
@@ -89,10 +89,14 @@ class JobChildStressTest : TestBase() {
                 launch(pool + deferred) {
                     deferred.complete(Unit) // Transition deferred into "completing" state waiting for current child
                     // **Asynchronously** submit task that launches a child so it races with completion
-                    pool.executor.execute {
-                        rogueJob.set(launch(pool + deferred) {
-                            throw TestException("isCancelled: ${coroutineContext.job.isCancelled}")
-                        })
+                    try {
+                        pool.executor.execute {
+                            rogueJob.set(launch(pool + deferred) {
+                                throw TestException("isCancelled: ${coroutineContext.job.isCancelled}")
+                            })
+                        }
+                    } catch (_: RejectedExecutionException) {
+                        // This is expected if the pool is closed
                     }
                 }