拆解Plaid的DataManager用Coroutines并发加载、取消与分页3个数据源【免费下载链接】plaidAn Android app which provides design news inspiration as well as being an example of implementing material design.项目地址: https://gitcode.com/gh_mirrors/pl/plaidPlaid 是 Google 出品的 Android 设计资讯聚合应用它的DataManager类用 Kotlin Coroutines 同时并发加载 Designer News、Product Hunt 和 Dribbble 这 3 个数据源并完整演示了协程的并发、取消、分页三大核心场景是学习协程数据层设计的绝佳范本。Plaid 是什么Plaid 把设计师社区Designer News、新品发布平台Product Hunt和设计师作品站Dribbble的内容聚合成一个 Material Design 信息流。用户可以在顶部添加/移除数据源筛选器信息流便会实时增删对应内容——而这一切背后的调度中枢就是本文的主角DataManager。先看架构DataManager 处于哪一层DataManager位于 core 模块的数据层它对上只暴露两类能力数据产出通过OnDataLoadedCallback把加载到的PlaidItem列表交给上层加载状态实现DataLoadingSubject接口对外广播开始加载 / 加载结束事件。它对下则依赖 3 个 UseCase 和一个 Repository 来真正取数LoadStoriesUseCaseDesigner News 热门文章LoadPostsUseCaseProduct Hunt 帖子ShotsRepositoryDribbble 作品搜索依赖由 Dagger 统一注入见 DataManagerModule.kt。每个数据源都通过统一的密封类 ResultSuccess/Error返回结果错误处理因此保持一致。并发加载一个 SupervisorJob 管所有源核心实现在 DataManager.ktprivate val parentJob SupervisorJob() private val scope CoroutineScope(dispatcherProvider.computation parentJob)两个设计点值得品味SupervisorJob一个数据源的协程失败不会取消兄弟协程。比如 Dribbble 网络超时Designer News 的加载依旧继续。computation调度器调度器的选择被封装在 CoroutinesDispatcherProvider 中生产用Dispatchers.Default测试时可直接替换成TestCoroutineDispatcher这让整个数据层可单测。每次加载更多时loadMore()遍历所有启用的数据源为每个源launch一个独立协程并存入parentJobs这个Map请求, Job中L98-L100。由于每次 launch 只是点火不阻塞3 个源天然并行请求网络。分页每个数据源独立记页分页状态用一个pageIndexes映射维护sourceKey - 当前页码InFlightRequestData(key, page)则标识正在飞的请求。getNextPageIndex()每次取页前先自增L130-L137保证同一数据源翻到下一页。一个容易踩坑的细节Product Hunt 的 API 页码从 0 开始而 DataManager 内部统一从 1 开始计数launchLoadProductHunt里做了data.page - 1的本地换算L194-L201——对外统一、对内兼容是很好的分页适配示范。取消按源取消与全量取消DataManager在构造时向SourcesRepository注册了一个筛选器监听L66-L80形成两条取消路径用户关闭某个数据源只cancel()该 key 对应的那个 Job并把它翻页状态重置为 0重新开启时从头加载页面销毁cancelLoading()遍历parentJobs全部取消并清空L102-L105。上层的调用点在 HomeViewModel.ktonCleared()里调用cancelLoading()保证用户离开首页后没有残留的挂起协程继续耗流量。这正是协程编程中作用域生命周期绑定思想的落地。加载状态原子计数器 回调广播并发场景下何时算全部加载完是个经典问题。DataManager用AtomicInteger loadingCount解决每发起一个源loadStarted()0→1 时通知开始每完成一个源loadFinished()1→0 时通知结束L207-L217。上层HomeViewModel注册回调后据此切换进度条 UIHomeViewModel.kt。接口定义见 DataLoadingSubject.kt——它不依赖 Rx纯回调 协程轻量且易测。一次完整的数据旅程用户上滑触发 InfiniteScrollListener剩余可见项 ≤5 时回调loadData()HomeViewModel调用dataManager.loadMore()切到 computation 线程为每个启用源launch协程计数器到 1UI 显示加载各源并行请求 API拿到Result.Success后打上数据来源标记、回调onDataLoaded刷新网格最后一个源完成计数器归 0UI 收起加载态若中途关闭页面cancelLoading()一键终止所有在途请求。小结场景Plaid 的解法可复用要点并发SupervisorJob 每源独立launch单点失败不影响兄弟任务取消Job 按 key 归档支持按源/全量取消生命周期结束时批量 cancel分页pageIndexes独立计数 0/1 基兼容状态与请求解耦可测调度器 Provider 抽象注入生产/测试双实现DataManager不到 250 行却把多数据源聚合的难点——并发、取消、分页、状态广播——全部演示了一遍值得作为协程数据层模板研读。【免费下载链接】plaidAn Android app which provides design news inspiration as well as being an example of implementing material design.项目地址: https://gitcode.com/gh_mirrors/pl/plaid创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考
拆解Plaid的DataManager用Coroutines并发加载、取消与分页3个数据源【免费下载链接】plaidAn Android app which provides design news inspiration as well as being an example of implementing material design.项目地址: https://gitcode.com/gh_mirrors/pl/plaidPlaid 是 Google 出品的 Android 设计资讯聚合应用它的DataManager类用 Kotlin Coroutines 同时并发加载 Designer News、Product Hunt 和 Dribbble 这 3 个数据源并完整演示了协程的并发、取消、分页三大核心场景是学习协程数据层设计的绝佳范本。Plaid 是什么Plaid 把设计师社区Designer News、新品发布平台Product Hunt和设计师作品站Dribbble的内容聚合成一个 Material Design 信息流。用户可以在顶部添加/移除数据源筛选器信息流便会实时增删对应内容——而这一切背后的调度中枢就是本文的主角DataManager。先看架构DataManager 处于哪一层DataManager位于 core 模块的数据层它对上只暴露两类能力数据产出通过OnDataLoadedCallback把加载到的PlaidItem列表交给上层加载状态实现DataLoadingSubject接口对外广播开始加载 / 加载结束事件。它对下则依赖 3 个 UseCase 和一个 Repository 来真正取数LoadStoriesUseCaseDesigner News 热门文章LoadPostsUseCaseProduct Hunt 帖子ShotsRepositoryDribbble 作品搜索依赖由 Dagger 统一注入见 DataManagerModule.kt。每个数据源都通过统一的密封类 ResultSuccess/Error返回结果错误处理因此保持一致。并发加载一个 SupervisorJob 管所有源核心实现在 DataManager.ktprivate val parentJob SupervisorJob() private val scope CoroutineScope(dispatcherProvider.computation parentJob)两个设计点值得品味SupervisorJob一个数据源的协程失败不会取消兄弟协程。比如 Dribbble 网络超时Designer News 的加载依旧继续。computation调度器调度器的选择被封装在 CoroutinesDispatcherProvider 中生产用Dispatchers.Default测试时可直接替换成TestCoroutineDispatcher这让整个数据层可单测。每次加载更多时loadMore()遍历所有启用的数据源为每个源launch一个独立协程并存入parentJobs这个Map请求, Job中L98-L100。由于每次 launch 只是点火不阻塞3 个源天然并行请求网络。分页每个数据源独立记页分页状态用一个pageIndexes映射维护sourceKey - 当前页码InFlightRequestData(key, page)则标识正在飞的请求。getNextPageIndex()每次取页前先自增L130-L137保证同一数据源翻到下一页。一个容易踩坑的细节Product Hunt 的 API 页码从 0 开始而 DataManager 内部统一从 1 开始计数launchLoadProductHunt里做了data.page - 1的本地换算L194-L201——对外统一、对内兼容是很好的分页适配示范。取消按源取消与全量取消DataManager在构造时向SourcesRepository注册了一个筛选器监听L66-L80形成两条取消路径用户关闭某个数据源只cancel()该 key 对应的那个 Job并把它翻页状态重置为 0重新开启时从头加载页面销毁cancelLoading()遍历parentJobs全部取消并清空L102-L105。上层的调用点在 HomeViewModel.ktonCleared()里调用cancelLoading()保证用户离开首页后没有残留的挂起协程继续耗流量。这正是协程编程中作用域生命周期绑定思想的落地。加载状态原子计数器 回调广播并发场景下何时算全部加载完是个经典问题。DataManager用AtomicInteger loadingCount解决每发起一个源loadStarted()0→1 时通知开始每完成一个源loadFinished()1→0 时通知结束L207-L217。上层HomeViewModel注册回调后据此切换进度条 UIHomeViewModel.kt。接口定义见 DataLoadingSubject.kt——它不依赖 Rx纯回调 协程轻量且易测。一次完整的数据旅程用户上滑触发 InfiniteScrollListener剩余可见项 ≤5 时回调loadData()HomeViewModel调用dataManager.loadMore()切到 computation 线程为每个启用源launch协程计数器到 1UI 显示加载各源并行请求 API拿到Result.Success后打上数据来源标记、回调onDataLoaded刷新网格最后一个源完成计数器归 0UI 收起加载态若中途关闭页面cancelLoading()一键终止所有在途请求。小结场景Plaid 的解法可复用要点并发SupervisorJob 每源独立launch单点失败不影响兄弟任务取消Job 按 key 归档支持按源/全量取消生命周期结束时批量 cancel分页pageIndexes独立计数 0/1 基兼容状态与请求解耦可测调度器 Provider 抽象注入生产/测试双实现DataManager不到 250 行却把多数据源聚合的难点——并发、取消、分页、状态广播——全部演示了一遍值得作为协程数据层模板研读。【免费下载链接】plaidAn Android app which provides design news inspiration as well as being an example of implementing material design.项目地址: https://gitcode.com/gh_mirrors/pl/plaid创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考
