Haskell：TMVar与MVar

问题描述

我想要一个小的操作，其中一个线程将某个值添加到共享状态，而另一个线程将值取出并打印出来。这是分别使用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

解决方法

您正在使用readTMVar，它只是查看TMVar中的内容。我想您是想使用takeTMVar来给另一个线程一个机会，在其中添加新内容。