作者:mobiledu2502872883 | 来源:互联网 | 2024-11-01 11:26
在消息分发过程中,使用`for`循环时可能会遇到新消息不断进入的问题,这需要一些特定的处理技巧。`LiveData`类提供了一种有效的解决方案,通过私有布尔变量`mDispatchingValue`来控制消息的分发过程,确保消息的有序和高效处理。此外,还可以结合`Observer`模式来进一步优化消息传递的可靠性和响应性。
用一个for循环分发消息的时候会碰到for执行的过程中有新的消息进来,这个处理起来就需要一点技巧,LiveData这个类给出了一个实现:
private boolean mDispatchingValue;
private boolean mDispatchInvalidated;
private 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;
}
它定义了两个变量:"mDispatchInvalidated"和“mDispatchingValue”,先看它的处理主体,do...while循环,条件是mDispatchInvalidated,进入执行mDispatchInvalidated的值被设置为false,如果传入的参数是NULL,走else把所有的消息遍历一遍分发下去处理,如果这个循环在执行的过程中有新的消息,mDispatchInvalidated的值就被设置为true,for循环中断,进入do...while循环,等于是更新了一个循环列表,把新增加的数据添进来for循环遍历执行。
如果传入的参数非空,把传入数据处理掉后中while中检查mDispatchInvalidated是否为true,如果当前处理过程中执行的过程中有新数据产生,那么走do...while中的for循环把新数据处理一遍退出。
这个方法写的非常精练。