使用Google Cloud Firestore BulkWriter为何导致JVM无法正常关闭？

• 必须显式关闭BulkWriter实例：Firestore的BulkWriter内部维护独立的后台线程池，即便所有操作完成、调用了flush()，线程池仍可能保持活跃状态。务必在批量操作全部完成后，单独调用bulkWriter.close()，而非仅关闭Firestore实例。
• 等待BulkWriter完全终止：close()方法是异步执行的，需要搭配awaitTermination()等待后台线程彻底结束，示例代码：

  bulkWriter.close()
  bulkWriter.awaitTermination(10, TimeUnit.SECONDS)
  

• 确认无未完成异步任务：通过监听BulkWriter.WriteResult的回调，确保所有提交的批量操作都已处理完毕，没有pending任务残留。
• 使用use块管理BulkWriter生命周期：如果BulkWriter实现了AutoCloseable接口，直接用use块包裹，会自动在代码块结束后调用close()：

  firestore.bulkWriter().use { bulkWriter ->
      // 执行批量写入操作
      bulkWriter.flush()
  }
  

• 排查线程池配置：如果自定义了Firestore客户端的线程池参数，需检查核心线程数、关闭策略等配置，确保后台线程能被正确回收。

你遇到的问题核心在于BulkWriter的线程管理与Firestore实例是分离的，仅关闭Firestore无法终止BulkWriter的后台线程，必须单独处理其生命周期。

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