Kotlin中如何同步即时访问Firestore离线缓存数据？

Firestore Android SDK 本身没有提供直接的同步读取缓存的公开接口，所有缓存读取逻辑都是基于异步Task封装的，要实现同步返回获取到的缓存数据，核心是通过线程阻塞等待捕获异步任务的返回值，过程中需要严格控制调用线程，避免触发应用ANR。

两种可落地的实现方式 #

• 协程场景下的最优实现
  引入kotlinx-coroutines-play-services依赖后，可以直接通过runBlocking配合SDK自带的await()挂起扩展，省去手动写回调的冗余代码，示例代码：

  fun getCachedUserSync(userID: String): DocumentSnapshot? = runBlocking(Dispatchers.IO) {
      try {
          db.collection("users").document(userID)
              .get(Source.CACHE)
              .await()
      } catch (e: Exception) {
          // 缓存中无对应文档时会抛出明确异常，可根据业务需要做自定义处理
          null
      }
  }
  

  注意事项：必须把阻塞执行的上下文指定为IO调度器，禁止直接在主线程调用该方法，否则会因为线程阻塞触发应用无响应。

• 无协程依赖的传统实现
  老项目如果还没有引入协程，可以通过CountDownLatch实现异步转同步的逻辑，示例代码：

  fun getCachedUserSyncWithoutCoroutine(userID: String): DocumentSnapshot? {
      val countDownLatch = CountDownLatch(1)
      var cachedResult: DocumentSnapshot? = null
  
      db.collection("users").document(userID).get(Source.CACHE)
          .addOnCompleteListener { task ->
              cachedResult = if (task.isSuccessful) task.result else null
              countDownLatch.countDown()
          }
  
      // 加1秒超时兜底，避免极端场景下无限阻塞
      countDownLatch.await(1, TimeUnit.SECONDS)
      return cachedResult
  }
  

  注意事项：该方法同样需要在后台线程中调用，由于读缓存本质是本地磁盘IO，正常情况下载入耗时接近瞬时，不会造成明显的线程等待。

关键避坑提示 #

• 即使是读本地缓存，也不要将上述同步方法放在主线程执行：首次加载缓存时Firestore需要读取本地持久化索引，极端情况下会有几毫秒到几十毫秒的耗时，直接在主线程调用有触发系统卡顿监测的风险。
• 当缓存中不存在目标文档时，异步任务会返回失败状态，此时直接取task.result会抛出异常，必须先判断task.isSuccessful再获取结果。
• 如果你的代码链路本身支持协程，不需要特意封装成同步阻塞方法，直接把获取缓存的逻辑写成suspend函数配合await()使用即可，阻塞式的同步实现仅适用于现有代码链路完全无法改造为挂起函数的场景。

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