观察者模式与有状态可观察范式

Question

在一个Android应用程序的开发过程中，我遇到了这个设计难题，我现在无法解决。我将感谢任何想法、变通方法或干净的解决方案：）我将尽可能地简化它：

一切都是从一个通用的观察者模式实现开始的。有一个主题在它的公共方法调用时改变状态；有观察者对这些变化作出相应的反应。在这种情况下，主题是一个有状态的主题，这意味着它有一个像自动机一样变化的内部状态控制器（一个int）。每次它的状态发生变化时,它都会像往常一样通知观察者：

• 客户端->subject.AnyMethod（）//将subject状态更改为状态X
• subject->notifyObservers（newState）//subject通知新状态X
• 观察者->subject.getData（）//检索数据

但现在想到这种情况：

• 客户端->subject.AnyMethod（）//将subject状态更改为状态X
• subject->notifyObservers(X)//subject第一个通知瀑布
• 观察者A->subject.AnyMethod（）//更改以状态Y为准
• 主题->notifyObservers(Y)//启动第二个通知瀑布

现在将要发生的事情，由于第二个瀑布,下一个观察者（比方说观察者）将以状态Y（从最后一秒瀑布）接收到通知，相应地操作，当第二个瀑布结束时，PC（程序计数器）将继续第一个通知瀑布，并重新生成观察者旧状态X。这产生了两个主要问题：第一个是观察者以错误的顺序得到新状态的通知（首先是状态Y，然后是状态X，当它应该是相反的方式）；第二个也是最重要的，即使是以错误的顺序得到通知，当观察者收到新状态X的通知时，它也是完全错误的，因为主体的真实状态是Y；这就产生了很多问题。

正如您可能已经意识到的那样，当观察者提交主题状态的更改时，当它得到通知而不是只得到来自主题的gettind数据时，就会发生这种情况。我会很感激任何其他的模式或解决方案。也是为了澄清只有一个线程。

提前道谢。

Answer 1

您需要的是某种同步状态传播的信号量。当subject传播状态更改时，它首先设置一个信号量，该信号量将锁定subject的任何其他状态更改（或简单地传播状态更改）。这也可以通过subject的观察者模式内部的堆栈来实现。只有在所有客户端都被告知状态更改之后，信号量才会被释放。通过这种方式，可以保证状态更改的发送按照在subject上执行的顺序到达所有客户端。

如果您使用状态机对上面的模型进行建模，那么您将使用历史状态机。