Haskell：TMVar 与 MVar

Question

我想要一个小操作，其中一个线程将一些值添加到共享状态，而另一个线程将值取出并打印出来。这是分别使用 TMVar 和 MVar 的两个版本。 TMVar 版本无法正常工作，它不断打印出第一个值。 STM第一个版本有什么问题？如何修复第一个 TMVar 版本以使其正常工作？

import Control.Concurrent (forkIO, takeMVar,newEmptyMVar,putMVar)
import Control.Monad (forM_, replicateM_)
import Control.Concurrent.STM (atomically, readTMVar, putTMVar, newEmptyTMVarIO)

n=10

main = do

    mvar<- newEmptyTMVarIO

    forkIO $ do
        forM_ [1..n] $ \x-> atomically $ do
            putTMVar mvar $! x

    replicateM_  n $ do
        a<- atomically $ readTMVar mvar
        print $ show a


main2 = do

    mvar<- newEmptyMVar

    forkIO $ do
        mapM_ (\x-> putMVar mvar x) [1..n]

    replicateM_  n $ do
        a<- takeMVar mvar
        print $ show a

Answer 1

您正在使用readTMVar，它只查看TMVar 中的内容。我想你的意思是使用takeTMVar 让其他线程有机会在其中添加新内容。