如何取消内部包含不可取消方法调用的Kotlin协程？

问题背景 #

现有如下Kotlin代码，期望process方法执行超时5秒后抛出超时异常（比如输入包含无限循环时），但实际超时机制未生效。原因是协程采用协作式取消机制，而调用的第三方库方法无法添加yield()这类协作逻辑。

// this method is used to evaluate the input string, and it returns evaluation result in string format
fun process(input: String): String {
    val timeoutMillis = 5000L
    val page = browser.newPage()
    try {
        val result = runBlocking {
            withTimeout(timeoutMillis) {
                val result = page.evaluate(input).toString()
                return@withTimeout result
            }
        }
        return result
    } catch (playwrightException: PlaywrightException) {
        return "Could not parse template! '${playwrightException.localizedMessage}'"
    } catch (timeoutException: TimeoutCancellationException) {
        return "Could not parse template! (timeout)"
    } finally {
        page.close()
    }
}

问题解答 #

1. 可以为此类协程设置超时 #

协程的协作式取消确实依赖被取消代码的配合，但针对第三方不支持协程协作的阻塞方法，我们可以通过将阻塞操作放到独立线程池执行+主动终止第三方操作的方式绕开限制，实现强制超时。

2. 具体实现方案 #

核心思路是把阻塞的page.evaluate调用切换到线程池执行，同时在超时触发时主动终止Playwright页面的执行，以此结束阻塞操作。修改后的代码示例：

fun process(input: String): String {
    val timeoutMillis = 5000L
    val page = browser.newPage()
    try {
        val result = runBlocking {
            withTimeout(timeoutMillis) {
                // 将阻塞操作切换到IO线程池，利用线程中断辅助取消
                withContext(Dispatchers.IO) {
                    page.evaluate(input).toString()
                }
            }
        }
        return result
    } catch (playwrightException: PlaywrightException) {
        return "Could not parse template! '${playwrightException.localizedMessage}'"
    } catch (timeoutException: TimeoutCancellationException) {
        // 超时后主动关闭页面，强制终止evaluate操作
        page.close()
        return "Could not parse template! (timeout)"
    } finally {
        // 确保页面最终被关闭
        if (!page.isClosed) {
            page.close()
        }
    }
}

如果page.evaluate不响应线程中断，主动调用page.close()是关键——这会直接终止Playwright页面的执行，从而结束阻塞的调用。

3. 无需改用Java线程 #

上述协程方案已能解决问题，且写法更简洁，还能复用线程池资源。如果改用Java线程，虽能通过ExecutorService+Future实现超时，但代码冗余度更高，不如协程方案优雅。

内容的提问来源于stack exchange，提问作者salat _