性能比较：映射 LiveData 值与流值

Question

目前，我正在 android 中尝试一些 livedata 和 flow。我不解的是，在映射 livedata 值和 flow 值时是否存在很大的性能差异，因为 livedata 映射是在主 ui 线程中执行的：

/**
 * Returns a [LiveData] mapped from `this` LiveData by applying [transform] to each value set on
 * `this` LiveData.
 *
 * This method is analogous to [io.reactivex.Observable.map].
 *
 * [transform] will be executed on the main thread.
 *
 * [...]
 **/
public inline fun <X, Y> LiveData<X>.map(crossinline transform: (X) -> Y): LiveData<Y> =
    Transformations.map(this) { transform(it) }

现在是诡计部分：假设我们有一个要映射的 livedata 值。由于映射是在 ui 线程中执行的，我们将 livedata 值转换为流值：

public fun <T> LiveData<T>.asFlow(): Flow<T> = flow {
    val channel = Channel<T>(Channel.CONFLATED)
    val observer = Observer<T> {
        channel.offer(it)
    }
    withContext(Dispatchers.Main.immediate) {
        observeForever(observer)
    }
    try {
        for (value in channel) {
            emit(value)
        }
    } finally {
        GlobalScope.launch(Dispatchers.Main.immediate) {
            removeObserver(observer)
        }
    }
}

将 livedata 观察者转换为流后，我们将值成功映射到另一个线程 (Dispatchers.IO)。但是现在我们不需要 ui 的流，所以我们将其转换回 livedata 值：

@JvmOverloads
public fun <T> Flow<T>.asLiveData(
    context: CoroutineContext = EmptyCoroutineContext,
    timeoutInMs: Long = DEFAULT_TIMEOUT
): LiveData<T> = liveData(context, timeoutInMs) {
    collect {
        emit(it)
    }
}

现在问题：

1. 与映射流值相比，映射 livedata 值是否对性能影响较大
2. 将 livedata 值转换为流值，然后将其转换回 livedata 是否会引入任何开销和/或性能问题？如果是，直接映射 livedata 值会更好吗？

一个映射示例是：

fun LiveData<WorkInfo>.collectStatus(): LiveData<Status<Unit>> = map { workInfo ->
    when(workInfo.state) {
        WorkInfo.State.ENQUEUED -> Status.loading()

        WorkInfo.State.RUNNING -> Status.loading()

        WorkInfo.State.SUCCEEDED -> Status.success(Unit)

        WorkInfo.State.BLOCKED -> Status.failed("Workmanager blocked")

        WorkInfo.State.FAILED -> Status.failed("Workmanager failed")

        WorkInfo.State.CANCELLED -> Status.failed("Workmanager cancelled")
    }
}

Answer 1

如果你想在不同的线程上执行映射，那么你应该使用LiveData.switchMap和liveData(context) { }

livedata.switchMap { 
    liveData(Dispatchers.IO) { 
        emit(someValue)
    }
}

或者摆脱 LiveData 并在任何地方使用 Flow/StateFlow/SharedFlow/Channel