ループが終了していません

Question

以下の機能は、デュアタイムが到来して復帰するまで受信して待ちます。

今、受信して応答すると動作します。 ackが受信されず、duetimeになるまで正常に動作します。

デュアタイムに達すると、フリーズします。私の自己構築ループを正しく終了していないようです。私はif-then-elseでも試しましたが、同じ結果です。私はwhileMを使いたくない。

ループを正しく終了するにはどうすればよいですか？

import Network.Socket hiding (send, sendTo, recv, recvFrom) 
import Network.Socket.ByteString 


waitAck s duetime' = do 
     print ("in") 
     (a, _) <- recvFrom s 4711 
     now' <- getPOSIXTime 
     unless (B.unpack a == "ack") (when (now' < duetime') (waitAck s duetime')) 
     print (B.unpack a) 
     return() 

Answer 1

正しい解決策は、2つのスレッド（ackを待機するスレッドと1つのスレッドを競合する）です。レースを失うものを殺す。 baseは、まさにこの目的のためにSystem.Timeout.timeoutを提供しているようです：

import Control.Concurrency.MVar 

withTimeout :: Int -> IO a -> IO (Maybe a) 
withTimeout n io = do 
    mvar <- newEmptyMVar 
    timeout <- forkIO (threadDelay n >> putMVar mvar Nothing) 
    action <- forkIO (io >>= putMVar mvar . Just) 
    result <- takeMVar mvar 
    killThread timeout 
    killThread action 
    return result 

waitAck s timeout = withTimeout timeout go where 
    go = do 
     (a, _) <- recvFrom s 4711 
     if B.unpack a == "ack" then print (B.unpack a) else go 

編集：おそらく、この（未テスト）コードは、あなたの方法についてのヒントを与えるだろう。その実装はこの実装よりも正しい可能性が高くなります。

Answer 2

これは反復ループではありません。あなたは再帰呼び出しの後に何か条件を置かないので、条件が最終的に失敗すると、すべてのものが巻き戻され、再帰呼び出しごとに1回印刷されます。私はそれが凍っているように見えるのではないかと思う。

このような何か試してください：あなたはすでにいくつかのデータを受け取ってきた後ので、あなたは `duetime'`をチェックするだけの時間がある

waitAck s duetime' = do 
    print ("in") 
    (a, _) <- recvFrom s 4711 
    now' <- getPOSIXTime 
    if B.unpack a == "ack" || now' >= duetime' 
     then print (B.unpack a) 
     else waitAck s duetime'