如何将Android BLE GATT异步回调转为同步实现？

绝对不推荐阻塞线程 #

不管是主线程还是后台线程，阻塞都不是合理选择：

• 主线程阻塞会直接触发ANR（应用无响应），Android明确禁止主线程执行任何等待/耗时操作；
• 后台线程阻塞会让线程处于闲置等待状态，浪费系统资源，而且一旦BLE操作超时、出错，还得额外处理线程唤醒逻辑，容易引入难以排查的bug。

最优方案：用Kotlin协程包装BLE异步回调 #

Kotlin协程是Android异步编程的标准方案，能把回调式的BLE API转换成更易读的同步风格代码，同时避免线程阻塞。核心是用suspendCancellableCoroutine将回调逻辑包装成挂起函数：

// 包装readCharacteristic为挂起函数
suspend fun BluetoothGatt.readCharacteristicSuspend(characteristic: BluetoothGattCharacteristic): BluetoothGattCharacteristic? =
    suspendCancellableCoroutine { continuation ->
        // 临时回调（实际项目中可以用全局回调+请求映射来复用，避免重复创建）
        val tempCallback = object : BluetoothGattCallback() {
            override fun onCharacteristicRead(
                gatt: BluetoothGatt?,
                targetChar: BluetoothGattCharacteristic?,
                status: Int
            ) {
                // 清理资源
                gatt?.setCharacteristicNotification(targetChar, false)
                
                if (status == BluetoothGatt.GATT_SUCCESS) {
                    continuation.resume(targetChar)
                } else {
                    continuation.resumeWithException(RuntimeException("特征值读取失败，状态码：$status"))
                }
            }
        }

        // 启动读取操作
        val readInitiated = this.readCharacteristic(characteristic)
        if (!readInitiated) {
            continuation.resumeWithException(RuntimeException("无法启动特征值读取"))
        }

        // 协程取消时清理资源，避免内存泄漏
        continuation.invokeOnCancellation {
            this.setCharacteristicNotification(characteristic, false)
            this.close()
        }
    }

使用示例（在协程作用域中调用）

比如在Activity/Fragment的lifecycleScope或ViewModel的viewModelScope中执行：

lifecycleScope.launch {
    try {
        // 自动挂起等待回调完成，不会阻塞线程
        val resultChar = gattInstance.readCharacteristicSuspend(targetCharacteristic)
        resultChar?.let {
            val value = it.value
            // 安全处理特征值（更新UI、计算逻辑）
        }
    } catch (e: Exception) {
        // 处理读取失败/超时等异常
        e.printStackTrace()
    }
}

可选方案：CompletableFuture（Java风格的Future/Promise） #

如果习惯Java的Future模式，也可以用CompletableFuture包装，但代码复杂度高于协程：

fun readCharacteristicFuture(gatt: BluetoothGatt, characteristic: BluetoothGattCharacteristic): CompletableFuture<BluetoothGattCharacteristic?> {
    val future = CompletableFuture<BluetoothGattCharacteristic?>()
    val callback = object : BluetoothGattCallback() {
        override fun onCharacteristicRead(gatt: BluetoothGatt?, characteristic: BluetoothGattCharacteristic?, status: Int) {
            if (status == BluetoothGatt.GATT_SUCCESS) {
                future.complete(characteristic)
            } else {
                future.completeExceptionally(RuntimeException("读取失败，状态码：$status"))
            }
        }
    }
    if (!gatt.readCharacteristic(characteristic)) {
        future.completeExceptionally(RuntimeException("启动读取失败"))
    }
    return future
}

使用示例（必须在后台线程调用，避免主线程阻塞）

Executors.newSingleThreadExecutor().submit {
    try {
        val result = readCharacteristicFuture(gattInstance, targetCharacteristic).get()
        // 处理结果，更新UI需切换到主线程
        runOnUiThread { /* 更新界面逻辑 */ }
    } catch (e: Exception) {
        e.printStackTrace()
    }
}

额外建议 #

1. 结合队列与协程串行执行：用单线程协程调度器（如Dispatchers.IO.limitedParallelism(1)）替代手动队列，既能保证同一时间仅执行一个BLE操作，又无需维护复杂的队列逻辑；
2. 添加超时处理：用协程的withTimeout设置读取超时，避免无限等待：

   lifecycleScope.launch {
       try {
           val result = withTimeout(5000) {
               gattInstance.readCharacteristicSuspend(targetCharacteristic)
           }
           // 处理结果
       } catch (e: TimeoutCancellationException) {
           // 超时逻辑
       }
   }
   

3. 资源清理：无论协程取消还是操作完成，务必及时关闭Gatt连接、取消特征通知，避免内存泄漏。

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