We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent c253929 commit aab779bCopy full SHA for aab779b
kotlinx-coroutines-core/jvm/src/internal/Concurrent.kt
@@ -29,10 +29,10 @@ private val REMOVE_FUTURE_ON_CANCEL: Method? = try {
29
@Suppress("NAME_SHADOWING")
30
internal fun removeFutureOnCancel(executor: Executor): Boolean {
31
try {
32
- val executor = executor as? ScheduledExecutorService ?: return false
+ val executor = executor as? ScheduledThreadPoolExecutor ?: return false
33
(REMOVE_FUTURE_ON_CANCEL ?: return false).invoke(executor, true)
34
return true
35
} catch (e: Throwable) {
36
- return true
+ return false // failed to setRemoveOnCancelPolicy, assume it does not removes future on cancel
37
}
38
0 commit comments