Kotlin协程suspendCancellableCoroutine结合Google ApiFuture回调挂起问题

1. ApiFuture线程池的非守护线程阻塞JVM退出：Google BigQuery的ApiFuture默认依赖的线程池使用非守护线程，这类线程不会随主线程结束自动终止。当用suspendCancellableCoroutine封装单个任务的await时，任务完成后线程池的核心线程仍会保持存活，直接阻止JVM进程退出，表现为程序看似挂起。
2. 并发数差异的影响：使用parMapUnordered且并发数>1时，arrow.fx.coroutines的内部调度逻辑会在所有任务完成后，间接触发线程池线程的空闲超时回收，JVM因此能正常退出；但并发数=1时，线程池核心线程不会触发超时回收逻辑，依旧保持活跃，导致程序挂起。
3. 内联回调的正常逻辑：内联回调写法中，业务逻辑在回调执行完成后没有额外的协程挂起等待，主线程执行完毕后，ApiFuture线程池的非核心线程会因无后续任务超时被回收，核心线程也会因客户端资源释放等逻辑终止，因此程序能正常退出。

办法1：配置BigQuery客户端使用守护线程池 #

创建自定义的ExecutorService并将线程设置为守护线程，通过BigQueryOptions指定该Executor，从根源避免非守护线程阻塞JVM：

val daemonExecutor = Executors.newFixedThreadPool(4) { runnable ->
    Thread(runnable).apply {
        isDaemon = true
        name = "bigquery-daemon-thread"
    }
}

val bigquery = BigQueryOptions.newBuilder()
    .setExecutor(daemonExecutor)
    // 补充项目ID、凭证等其他配置
    .build()
    .service

办法2：任务完成后手动关闭线程池 #

如果无法自定义客户端Executor，可在所有任务完成后，手动关闭ApiFuture对应的线程池：

// 假设持有ApiFuture使用的ExecutorService引用
executor.shutdown()
executor.awaitTermination(5, TimeUnit.SECONDS) // 等待线程池安全关闭

办法3：绑定守护线程调度器执行协程 #

将封装的suspend函数绑定到使用守护线程的自定义调度器，避免非守护线程残留：

val daemonDispatcher = Executors.newSingleThreadExecutor { runnable ->
    Thread(runnable).apply {
        isDaemon = true
    }
}.asCoroutineDispatcher()

runBlocking(daemonDispatcher) {
    val result = mySuspendAwaitFunction()
    // 业务逻辑处理
}
daemonDispatcher.close() // 任务完成后关闭调度器

办法4：兜底强制退出（不推荐） #

如果以上方案无法快速生效，可在所有任务完成后调用System.exit(0)强制终止JVM，但可能导致资源未正常释放，仅作为临时兜底方案。

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