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 让另一个线程有机会在其中添加一些新内容。

Haskell：TMVar 与 MVar

Haskell: TMVar vs MVar

concurrency

multithreading

haskell

stm