如何解决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
来给另一个线程一个机会,在其中添加新内容。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。