Kann ich sicherstellen, dass Haskell atomare IO ausführt?

Question

Ich habe zwei Threads in Haskell, die IO durchführen. (Sie drucken nur). So etwas wie die folgenden:

thread1 :: IO() 
thread1 = putStrLn "One" 

thread2 :: IO() 
thread2 = putStrLn "Two" 

Ich bin derzeit immer Ergebnisse wie folgt aus:

OnTwoe 
OTnweo 

Wie kann ich sicherstellen, dass jeder Thread atomar seine IO abgeschlossen?

Answer 1

Das ist eine gute Frage. Verwenden Sie eine Synchronisationsvariable, um den atomaren Zugriff auf die Ressource sicherzustellen. Ein einfacher Weg ist mit einem MVar:

main = do 
    lock <- newMVar() 
    forkIO $ ... lock 
    forkIO $ ... lock 

, nun IO zu tun, ohne Verschachtelung nimmt jeder Thread die Sperre:

thread1 lock = do 
     withMVar lock $ \_ -> putStrLn "foo" 

thread2 lock = do 
     withMVar lock $ \_ -> putStrLn "bar" 

Ein alternatives Design ist einen dedizierten Worker-Thread zu haben, die alle funktionieren die putStrLns, und Sie senden Nachrichten zum Ausdrucken über einen Chan.