具有状态更新的状态相关事件处理

Question

我想在我的项目中使用FRP(即反应香蕉0.6.0.0)(GDB/MI前端).但我在宣布活动网络方面遇到了麻烦.

GUI中有命令,GDB有停止事件.两者都需要处理,处理它们取决于系统的状态.

我目前的方法看起来像这样(我认为这是显示问题所需的最低复杂度):

data Command = CommandA | CommandB
data Stopped = ReasonA  | ReasonB
data State = State {stateExec :: Exec, stateFoo :: Int}
data StateExec = Running | Stopped

create_network :: NetworkDescription t (Command -> IO ())
create_network = do
    (eCommand, fCommand) <- newEvent
    (eStopped, fStopped) <- newEvent
    (eStateUpdate, fStateUpdate) <- newEvent

    gdb <- liftIO $ gdb_init fStopped

    let
      eState = accumE initialState eStateUpdate
      bState = stepper initialState eState

    reactimate $ (handleCommand gdb fStateUpdate <$> bState) <@> eCommand
    reactimate $ (handleStopped gdb fStateUpdate <$> bState) <@> eStopped

    return fCommand

handleCommand并handelStopped根据当前状态对命令和停止事件做出反应.可能的反应是调用(同步)GDB I/O函数和触发状态更新事件.例如:

handleCommand :: GDB -> ((State -> State) -> IO ()) -> State -> Command -> IO ()
handleCommand gdb fStateUpdate state CommandA = case stateExec state of
   Running -> do
     gdb_interrupt gdb
     fStateUpdate f
 where f state' = state' {stateFoo = 23}

问题是,当f评估时accumE,state'有时不同state.

我不是100%肯定,为什么会发生这种情况,因为我不完全理解的时间和同时性"reactimation"的反应香蕉的顺序语义.但是我想handleStopped可能会在f更改状态之前评估触发的状态更新函数.

无论如何,这个事件网络导致状态不一致,因为f"当前"状态的假设有时是错误的.

我一直试图解决这个问题超过一个星期,我只是想不通.任何帮助深表感谢.

Answer 1

看起来你想让一个eStateUpdate事件无论何时发生eStop还是eCommand发生？

如果是这样，您可以简单地将其表示为两个事件的并集：

let        
    eStateUpdate = union (handleCommand' <$> eCommand)
                         (handleStopped' <$> eStopped)

    handleCommand' :: Command -> (State -> State)
    handleStopped' :: Stopped -> (State -> State)

    eState = accumE initialState eStateUpdate

    etc.

请记住：事件的行为就像普通值一样，您可以将它们组合起来创建新的值，而不是编写一系列回调函数。

newEvent仅当您想从外部导入事件时才应使用该函数。eCommand和就是这种情况eStopped，因为它们是由外部 GDB 触发的，但该eStateUpdate事件似乎是网络内部的。

关于当前代码的行为，reactive-banana 在接收外部事件时始终执行以下操作：

1. 计算/更新所有事件发生和行为值。
2. reactimate按顺序运行s。

但很可能发生的是，步骤 2 再次触发网络（例如通过函数fStateUpdate），在这种情况下，网络计算新值并reactimate再次调用 s，作为此函数调用的一部分。此后，流量控制返回到reactimates仍在运行的第一个序列，第二次调用fStateUpdate将产生奇怪的效果：网络内部的行为已经更新，但此调用的参数仍然是旧值。像这样的东西：

reactimate1
reactimate2
    fStateUpdate      -- behaviors inside network get new values
        reactimate1'
        reactimate2'
reactimate3           -- may contain old values from first run!

显然，这很难解释，也很难推理，但幸运的是，如果您坚持上述指导原则，这是不必要的。

从某种意义上说，后一部分体现了以传统风格编写事件处理程序的复杂性，而前一部分体现了以 FRP 风格进行事件编程的（相对）简单性。

黄金法则是：

处理事件时不要调用另一个事件处理程序。

您不必遵守这条规则，它有时很有用；但如果你这样做的话事情就会变得复杂。