Kotlin Flows异步加载数据致UI阻塞问题及优化咨询

一、先排查你的实现是否存在这些常见问题 #

• 主线程处理数据逻辑：如果在collect的主线程回调里做分类匹配、批量往mutableListOf<Any>加元素的操作，哪怕只有13条数据，循环匹配、集合扩容这类操作也可能短暂阻塞主线程，导致加载指示器卡顿。
• Flow线程切换错误：如果Repository返回的Flow没在IO线程执行网络请求，直接在主线程触发请求，会直接卡住UI。
• RecyclerView全量刷新：每次更新数据都调用notifyDataSetChanged()，而不用DiffUtil做局部更新，会引发不必要的全量刷新，拖慢UI。
• 分类匹配逻辑低效：比如处理每个ProductDto都遍历所有CategoryDto找匹配，O(n*m)的时间复杂度，数据量小的时候也可能拖慢主线程。

二、针对性优化方案 #

1. 把数据处理移到IO线程 #

用flowOn(Dispatchers.IO)确保网络请求和数据转换全在后台完成，只把最终的展示列表切回主线程更新UI：

viewModelScope.launch {
    combine(
        categoryRepository.getCategories(),
        productRepository.getProducts(),
        serviceRepository.getServices()
    ) { categories, products, services ->
        // 所有数据处理都在IO线程执行
        val categoryMap = categories.associateBy { it.id } // 提前构建映射，O(1)查找
        val displayList = mutableListOf<Any>()
        
        // 按分类分组产品
        val productsByCategory = products.groupBy { it.categoryId }
        
        // 拼接分类名+对应产品
        categories.forEach { category ->
            displayList.add(category.name)
            productsByCategory[category.id]?.let { displayList.addAll(it) }
        }
        
        // 追加服务数据
        displayList.addAll(services)
        
        displayList
    }
    .flowOn(Dispatchers.IO) // 数据处理切到IO线程
    .collect { displayList ->
        // 主线程只做UI更新
        adapter.submitList(displayList)
        loadingIndicator.hide()
    }
}

2. 用DiffUtil实现局部刷新 #

让RecyclerView Adapter继承ListAdapter，利用DiffUtil自动计算差异并局部更新，避免全量刷新的性能损耗：

class MainAdapter : ListAdapter<Any, RecyclerView.ViewHolder>(DiffCallback()) {
    
    class DiffCallback : DiffUtil.ItemCallback<Any>() {
        override fun areItemsTheSame(oldItem: Any, newItem: Any): Boolean {
            return when {
                oldItem is String && newItem is String -> oldItem == newItem
                oldItem is ProductDto && newItem is ProductDto -> oldItem.id == newItem.id
                oldItem is ServiceDto && newItem is ServiceDto -> oldItem.id == newItem.id
                else -> false
            }
        }

        override fun areContentsTheSame(oldItem: Any, newItem: Any): Boolean {
            return oldItem == newItem
        }
    }
    
    // 实现ViewHolder和onBindViewHolder逻辑...
}

3. 优化加载指示器与渐进式UI更新 #

不用等所有数据处理完才更新UI，可以分阶段展示：先加载完分类就先显示分类标题，再异步加载产品追加进去，加载指示器可以在所有数据就绪后再隐藏，提升用户感知：

viewModelScope.launch {
    // 先加载分类并展示
    val categories = categoryRepository.getCategories().first()
    val categoryMap = categories.associateBy { it.id }
    val tempList = mutableListOf<Any>().apply { addAll(categories.map { it.name }) }
    adapter.submitList(tempList)
    
    // 后台加载产品和服务
    val products = productRepository.getProducts().first()
    val productsByCategory = products.groupBy { it.categoryId }
    val services = serviceRepository.getServices().first()
    
    // 构建完整展示列表
    val finalList = mutableListOf<Any>()
    categories.forEach { category ->
        finalList.add(category.name)
        productsByCategory[category.id]?.let { finalList.addAll(it) }
    }
    finalList.addAll(services)
    
    // 更新最终列表并隐藏加载指示器
    adapter.submitList(finalList)
    loadingIndicator.hide()
}.flowOn(Dispatchers.IO)

4. 避免主线程操作集合 #

不要在主线程直接修改mutableListOf<Any>再通知更新，而是在后台线程构建好完整列表后，一次性提交给Adapter，减少主线程的集合操作开销。

三、验证实现正确性的要点 #

• 确认categoryRepository.getCategories()的Flow是冷流，且在IO线程执行网络请求，保证分类加载完成后再处理产品。
• 检查产品与分类的关联逻辑：比如categoryMap[product.categoryId]是否能正确匹配到对应分类，避免分类名称缺失。
• 确保所有Flow的collect操作在viewModelScope或lifecycleScope下执行，防止内存泄漏。

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