wxhaskell異步更新

Question

我正在使用WxHaskell以圖形方式顯示使用TCP（我使用Data.Binary解碼）通告狀態更新的程序的狀態。收到更新時，我想更新顯示。所以我希望GUI以異步方式更新它的顯示。我知道processExecAsync異步運行命令行進程，但我不認爲這是我想要的。

Answer 1

這是使用事務變量（即軟件事務內存）的粗略代碼。你可以使用IORef，MVar或其他許多構造。

main = do 
    recvFunc <- initNetwork 
    cntTV <- newTVarIO 0 
    forkIO $ threadA recvFunc cntTV 
    runGUI cntTV 0 

上方啓動該程序，初始化網絡和共享變量cntTV

threadA recvCntFromNetwork cntTVar = forever $ do 
    cnt <- recvCntFromNetwork 
    atomically (writeTVar cntTVar cnt) 

threadA從網絡接收數據和寫入計數器的共享變量的新值。

runGUI cntTVar currentCnt = do 
    counter <- initGUI 
    cnt <- atomically $ do 
     cnt <- readTVar cntTVar 
     if (cnt == currentCnt) 
      then retry 
      else return cnt 
    updateGUICounter counter cnt 
    runGUI cntTVar cnt 

runGUI讀取共享變量，如果有變化將更新GUI計數器。僅供參考，runGUI線程不會在retry上被喚醒，直到cntTVar被修改，所以這不是一個CPU佔用輪詢循環。

在這段代碼中，我假設你有函數updateGUICounter,initGUI和initNetwork。我建議你使用Hoogle來查找你還不知道的其他功能的位置，並學習一些關於每個模塊的知識。

Answer 2

我想出了一種似乎可行的hack。也就是說，使用事件計時器來檢查更新隊列：

startClient :: IO (TVar [Update]) 
startClient = /*Connect to server, 
       listen for updates and add to queue*/ 

gui :: TVar [Update] -> IO() 
gui trdl = do 
    f <- frame [text := "counter", visible := False] 
    p <- panel f [] 
    st <- staticText p [] 
    t <- timer f [interval := 10, on command := updateGui st] 
    set f [layout := container p $ fill $ widget st, clientSize := (sz 200 100), visible := True] 
where 
    updateGui st = do 
      rdl <- atomically $ readTVar trdl 
      atomically $ writeTVar trdl [] 
      case rdl of 
       [] -> return() 
       dat : dl -> set st [text := (show dat)] 

main :: IO() 
main = startClient >>= start gui 

因此，客戶端偵聽TCP連接上的更新，將它們添加到隊列中。每隔10ms，就會發起一個事件，其操作是檢查此隊列並在靜態文本小部件中顯示最新更新。

如果您有更好的解決方案，請告訴我！

Answer 3

我發現在沒有忙等待一個解決方案： http://snipplr.com/view/17538/

然而，你可能會爲了避免與現有的ID衝突選擇更高的事件ID。

這裏是我的模塊http://code.haskell.org/alsa/gui/src/Common.hs一些代碼：

myEventId :: Int 
myEventId = WXCore.wxID_HIGHEST+100 
    -- the custom event ID, avoid clash with Graphics.UI.WXCore.Types.varTopId 

-- | the custom event is registered as a menu event 
createMyEvent :: IO (WXCore.CommandEvent()) 
createMyEvent = 
    WXCore.commandEventCreate WXCore.wxEVT_COMMAND_MENU_SELECTED myEventId 

registerMyEvent :: WXCore.EvtHandler a -> IO() -> IO() 
registerMyEvent win io = 
    WXCore.evtHandlerOnMenuCommand win myEventId io 


reactOnEvent, reactOnEventTimer :: 
    SndSeq.AllowInput mode => 
    Int -> WX.Window a -> Sequencer mode -> 
    (Event.T -> IO()) -> 
    IO() 
reactOnEvent _interval frame (Sequencer h _) action = do 
    mvar <- MVar.newEmptyMVar 

    void $ forkIO $ forever $ do 
     MVar.putMVar mvar =<< Event.input h 
     WXCore.evtHandlerAddPendingEvent frame =<< createMyEvent 

    registerMyEvent frame $ 
     MVar.takeMVar mvar >>= action 

-- naive implementation using a timer, requires Non-Blocking sequencer mode 
reactOnEventTimer interval frame sequ action = 
    void $ 
    WX.timer frame [ 
     WX.interval := interval, 
     on command := getWaitingEvents sequ >>= mapM_ action] 

的代碼顯示了兩種方式來處理這個問題：

• reactOnEventTimer不使用WX定時器忙等待。
• reactOnEvent只有在事件實際到達時纔會激活。這是首選解決方案。

在我的例子中，我等待ALSA MIDI音序器消息。 Event.input調用等待下一個ALSA消息。 action獲取Event.input的結果，即傳入的ALSA消息，但它在WX線程中運行。