Jetpack系列之LiveData详解
admin
2024-03-27 15:30:01
0

(一)概述 

LiveData is a data holder class that can be observed within a given lifecycle. This means that an Observer can be added in a pair with a LifecycleOwner, and this observer will be notified about modifications of the wrapped data only if the paired LifecycleOwner is in active state.

从LiveData源码描述来看,LiveData是一个可以在给定生命周期内观察到的数据持有者类。
这意味着可以将一个观察者添加到一对LifecycleOwner中,并且只有当配对的LifecycleOwner处于活动状态时,才会通知该观察者关于包装数据的修改。
结合上面的ViewModel分析,可以看出LiveData也是一个与LifecycleRegistry(所谓的“感知生命周期”)相关的组件,而且只有当界面的生命周期处于活跃状态时,观察者才能收到数据更新的通知。

(二)源码解析

一般 livedata通过传入LifecycleOwner监听数据变化(或者说订阅消息):

livedata.observe(getViewLifecycleOwner()) {data->// onChanged()
}

那么livedata持有的数据(mData)什么时候发射呢?也就是这个onChanged() 什么时候会触发呢?
先看observe源码:

    @MainThreadpublic void observe(@NonNull LifecycleOwner owner, @NonNull Observer observer) {assertMainThread("observe");if (owner.getLifecycle().getCurrentState() == DESTROYED) {// ignore // 如果页面(fragment/activity...)持有的当前的lifecycle处于DESTROYED状态则不处理return;}// 把observer包装成与lifecycle生命周期关联的LifecycleBoundObserver对象LifecycleBoundObserver wrapper = new LifecycleBoundObserver(owner, observer);// 然后放入mObservers(map)中返回wrapper本身,如果observer有对应的wrapper则直接返回wrapper。ObserverWrapper existing = mObservers.putIfAbsent(observer, wrapper);// 如果observer已经添加并且不是同一个owner,则抛异常if (existing != null && !existing.isAttachedTo(owner)) {throw new IllegalArgumentException("Cannot add the same observer"+ " with different lifecycles");}// 如果observer已经添加则不处理,反之将wrapper添加到lifecycle生命周期中if (existing != null) {return;}owner.getLifecycle().addObserver(wrapper);}

大致逻辑:把observer先包装成LifecycleBoundObserver添加到lifecycle中。
再看liveData里面的几个主要方法:

private final Runnable mPostValueRunnable = new Runnable() {@SuppressWarnings("unchecked")@Overridepublic void run() {Object newValue;synchronized (mDataLock) {// 待发数据赋给临时变量newValue = mPendingData;// 重置(说明待发数据已处理)mPendingData = NOT_SET;}// 发射数据setValue((T) newValue);}};
protected void postValue(T value) {boolean postTask;synchronized (mDataLock) {postTask = mPendingData == NOT_SET;mPendingData = value;}if (!postTask) {return;}// 交由异步线程处理ArchTaskExecutor.getInstance().postToMainThread(mPostValueRunnable);}
@MainThreadprotected void setValue(T value) {assertMainThread("setValue");mVersion++;// 标记发射次数mData = value;dispatchingValue(null);// wrapper传null}
可以看出postValue最终还是调用setValue,

之后交由dispatchingValue处理,如果wrapper不为空则只分发给它,反之分发给所有的observer (setValue/postValue).

void dispatchingValue(@Nullable ObserverWrapper initiator) {if (mDispatchingValue) {mDispatchInvalidated = true;return;}mDispatchingValue = true;do {mDispatchInvalidated = false;if (initiator != null) {considerNotify(initiator);initiator = null;} else {for (Iterator, ObserverWrapper>> iterator =mObservers.iteratorWithAdditions(); iterator.hasNext(); ) {considerNotify(iterator.next().getValue());if (mDispatchInvalidated) {break;}}}} while (mDispatchInvalidated);mDispatchingValue = false;}

最终调用considerNotify,触发observer的onChange回调:

private void considerNotify(ObserverWrapper observer) {if (!observer.mActive) {// observer不是活跃状态则不处理return;}...if (!observer.shouldBeActive()) {// lifecycle低于STARTED状态,则更新当前observer为不活跃状态observer.activeStateChanged(false);return;}if (observer.mLastVersion >= mVersion) {// 如果当前observer的发射次数比livedata的发射次数还高,也不处理。return;}observer.mLastVersion = mVersion;// 更新versionobserver.mObserver.onChanged((T) mData);// 触发observer的onChange回调。}

通过上面可以知道,我们主动调用setValue/postValue给dispatchingValue方法传的都是null,会遍历发射数据给所有活跃的观察者,那什么时候dispatchingValue传的不为null呢?
代码追溯:LifecycleRegistry.dispatchEvent(LifecycleOwner, Event) —> onStateChanged —> activeStateChanged —> dispatchingValue,最终又又又回到了 LifecycleRegistry(一个可以感知生命周期的家伙),上面分析ViewModel已经分析过了,不再赘述。 另外observeForever订阅时,也会主动触发一个 dispatchingValue。

This class is designed to hold individual data fields of ViewModel, but can also be used for sharing data between different modules in your application in a decoupled fashion.
LiveData 设计用于保存ViewModel的各个数据字段,但也可以用于以解耦方式在应用程序中的不同模块之间共享数据

最后:谷歌建议与ViewModel结合使用(即viewmodel持有LiveData对象,如:方便页面数据共享时,各fragment都能订阅到数据变更),也可以用于不同模块间的数据共享。

(三)小结

livedata是一个感知生命周期的“订阅消息”的组件,由于观察者会绑定到Lifecycle对象 wrapper(避免了内存泄露),并且只有当界面的生命周期处于活跃onActive()状态,观察者才能收到数据更新的通知(除非你直接或间接触发setValue/postValue主动发射操作,比如页面刷新)

相关内容

热门资讯

小棉袄电商洞察:短保零食爆火背... 当整个零食赛道还在价格战的泥潭里贴身肉搏时,长沙街头的一抹红蓝撞色,正用“新鲜”二字,悄然改写着游戏...
金价高位“吞没”!美元强势+获... 汇通财经APP讯——周三(2月26日)亚市早盘,现货黄金窄幅震荡,目前交投于5150美元/盎司附近。...
大疆反击美国禁令! 据路透社报道,中国无人机制造商大疆(DJI)周二表示,已提起诉讼,对美国联邦通信委员会(FCC)禁止...
AI算力需求刺激存储芯片股 兆... 来源:财联社 财联社2月24日讯(编辑 胡家荣)受益于海外市场消息利好,港股存储概念股走强。截至发稿...
2026年中国十大杰出品牌战略... 2026年,中国经济 将 在新质生产力驱动下稳健前行, 中国 企业竞争从产品、渠道层面升级为品牌心智...
原创 特... 一直以来,中美关系始终处于紧张状态,外部局势难以化解,特朗普却在国内遭遇了前所未有的压力。2月20日...
“红利+”指数集体涨超1%,关... 截至午间收盘,中证红利指数、国证价值100指数、国证自由现金流指数均上涨1.6%。Wind数据显示,...
ETF盘中资讯|低吸时刻?科创... 或被海外AI情绪错杀,重点布局国产AI产业链的科创人工智能ETF(589520)连跌两日,场内价格现...
哈登20分米切尔23分 骑士大... 【搜狐体育战报】北京时间2月25日NBA常规赛,主场作战的骑士以109-94击败尼克斯。阿伦19分1...
科创京津冀|十二年“聚链成群”... 2026年,京津冀协同发展迎来12周年。十二年时间,足够一个产业完成从“点”到“链”的蜕变。 早在2...
金价高位震荡!实探深圳水贝市场... 2月24日,农历正月初八,深圳水贝贵金属市场在春节“不打烊”的喧嚣后,迎来了马年首个正式工作日。尽管...
日照国资内部大调整:城投集团1... 经济导报记者 杨佳琪 2月24日,日照城投集团有限公司(下称“日照城投集团”)发布关于控股股东发生变...
南京商业大佬正式入主南通这家上... 2月24日晚间,南通上市公司*ST金灵披露公司控股股东和实际控制人变更的提示性公告。 根据《重整计划...
高特电子股权合规疑云:董事牵线... 来源丨时代商业研究院 作者丨陆烁宜 编辑丨郑琳 高校教师隐秘入股、其兄牵线融资获顾问费且获得员工持股...
大市“开门红”,白酒逆市调整,... 春节假期后首个交易日,白酒走出了“逆市”行情。 2月24日,A股大盘高开并收盘企稳4100点以上,但...
别让声誉危机,成为你融资路上的... 资本市场从来没有“温情脉脉”,只有“优胜劣汰”的残酷法则。一句广为流传的警示,道尽了企业发展的隐秘风...
钨价上涨颠覆传统逻辑,APT破... 2月25日,据中钨在线最新消息,一年来,钨价的高强度和快节奏走势,已基本颠覆了原有市场传统的交易逻辑...
波兰经济学教授:美国关税政策混... 美国最高法院20日裁定美国《国际紧急经济权力法》未授权总统大规模征收关税,美国总统特朗普当天宣布将对...
暴跌54%!非洲“一哥”跌落神... 作者:曾有为 那个曾经在非洲所向披靡、被誉为“手机中的战斗机”的传奇公司,在2026年初,交出了一份...
5个月内两次更替,涪陵榨菜迎“... 瑞财经 刘治颖 2月13日,涪陵榨菜(SZ002507)公告,提名夏强伟担任公司总经理,公司董事长、...