MVP中的观察者模式

Question

我有一个系统（游戏），我尝试使用架构模型视图呈现器来实现它。我现在所做的是演示者中的while循环，它不断调用视图方法来显示。我这样做的方式是使用Producer/Consumer模式，其中View为触摸事件（Android）注册和事件处理程序，并生成相应的触摸实例，演示者在while循环中使用。

现在我想在模型和演示者之间使用模式观察者/Suscriber。使用这个模式，演示者将是观察者订阅模型状态的变化。问题是，演示者将执行模型中的更新，相应于视图中发生的事件。每次演示者执行一个方法in.the模型，就有可能改变它的状态并通知演示者。我将在另一个线程中为每次更新分离模型，但是如果它在while循环中的不同线程中运行，我如何通知演示者？如果我调用方法通知观察者，演示者什么时候会调用相应的方法？

我快疯了！我需要你们的帮助，队长们！

Answer 1

就架构而言，你可能过度设计了这个。MVP、生产者/消费者和观察者都在同一个帖子里。警钟正在敲响。我怀疑你不需要生产者/消费者或观察者模式，MVP可能完全足够了。

试试这个。

创建3个文件:

• GameFragment.java
• GameView.java
• GamePresenter.java

public class GamePresenter {
    private final GameView view;

    public GamePresenter(GameView view){
        this.view = view;
        NetworkController.addObserver(this);//listen for events coming from the other player for example. 
    }

    public void onSwipeRight(){
        // blah blah do some logic etc etc
        view.moveRight(100);
        NetworkController.userMovedRight();
    }

    public void onNetworkEvent(UserLeftGameEvent event){
        // blah blah do some logic etc etc
        view.stopGame()
    }
}

是一个接口

public interface GameView {
    void stopGame();
    void moveRight(int pixels);
}

游戏片段是一个扩展片段并实现游戏视图的类，并且有一个游戏演示者作为成员。

public class GameFragment extends Fragment implements GameView {
    private GamePresenter presenter;

    @Override
    public void onCreate(Bundle savedInstanceState){
        presenter = new GamePresenter(this);
    }
}

这种方法的关键是清楚地了解每个文件的作用。

片段控制任何与视图相关的内容（按钮，文本视图等）。它通知演示者用户交互。

呈现者是引擎，它从视图中获取信息(在这种情况下，它是片段，但是请注意，这种模式非常适合依赖注入？这不是巧合。演示者不知道视图是一个片段——它不关心),并将其与从“下面”接收的信息(通信、数据库等)相结合，然后相应地命令视图。

视图只是演示者与视图通信的接口。请注意，这些方法读取为命令，而不是问题（例如getViewState（）），也不是通知（例如onPlayerPositionUpdated（））-命令（例如movePlayerHere（int posithtml" target="_blank">ion））。

Answer 2

没关系。你有一个对象，Presenter，它正在线程内部的无限循环中使用。这并不意味着你不能调用它的方法，而它也被线程调用。你唯一要考虑的是，如果线程正在读取/使用的数据被观察者通知改变了，你应该同步它的访问。

因此，总而言之，当Presenter在无限循环中运行时，对其方法的任何调用都将立即得到响应（除非它们具有同步访问权限，在这种情况下，它将阻塞，直到它获得锁所有权）

以下完全没问题:

class Presenter implements IObserver
{
    public void aMethod() { }

    public void notifyObserver() { }
}

class Model
{
    private List<IObserver> observers = new ArrayList<>();

    public void addObserver(IObserver obs) { observers.add(obs); }

    public void notifyObservers()
    {
        for(IObserver o : observers) { o.notifyObserver(); }
    }
}


final Presenter myPresenter = new Presenter();
Model myModel = new Model();
myModel.add(myPresenter);

new Thread(new Runnable() 
{
    @Override
    public void run()
    {
        while(true)
        {
            myPresenter.aMethod();
        }           
    }
).start();