multithreading - Haskell:STM事务中无限期阻塞的线程

Question

有什么方法可以增加时间间隔，RTS 在此基础上决定线程在 STM 事务中无限期阻塞？
这是我的代码:

import Control.Concurrent (ThreadId)
import Control.Concurrent.MVar (MVar,newMVar,withMVar)
import Control.Concurrent.STM
import qualified Control.Concurrent.ThreadManager as TM

data ThreadManager = ThreadManager { tmCounter::TVar Int, tmTM::MVar TM.ThreadManager }

data Settings = Settings {
    maxThreadsCount::Int }

createThreadManager :: Settings -> IO ThreadManager
createThreadManager s = do
    counter <- atomically $ newTVar (maxThreadsCount s)
    tm <- TM.make >>= newMVar
    return $ ThreadManager counter tm

forkManaged :: ThreadManager -> IO () -> IO ThreadId
forkManaged tm fn = do
    atomically $ do
        counter <- readTVar $ tmCounter tm
        check $ counter > 0
        writeTVar (tmCounter tm) (counter - 1)
    withMVar (tmTM tm) $ \thrdmgr -> TM.fork thrdmgr $ do
        fn
        atomically $ do
            counter <- readTVar $ tmCounter tm
            writeTVar (tmCounter tm) (counter + 1)

叉管理 确保同时运行的托管线程的数量不超过 最大线程数 .它工作正常，直到重载。在重负载下，RTS 会引发异常。我认为在重负载下，在激烈的并发资源竞争中，一些线程没有时间访问 STM 上下文。所以我认为，增加 RTS 决定抛出此异常的时间间隔可能会解决问题。

Answer 1

丹尼尔瓦格纳是对的。该决定不是在超时的情况下做出的。 rts中的相关代码在 Schedule.c

见 resurrectThreads抛出异常的函数。注释描述了这仅被扔给在 GC 之后发现为垃圾的线程。 ezyang 描述了这对 mvar 是如何工作的:http://blog.ezyang.com/2011/07/blockedindefinitelyonmvar/

[关于 check 的错误猜测|当我检查它的来源并意识到它只是一个简单的保护/重试而不是早期论文中描述的内容时删除了 - 哎呀!我现在怀疑 Daniel Wagner 在这里也是正确的，问题在于计数器没有增加。]