Haskell: поток заблокирован на неопределенный срок в транзакции STM

Есть ли способ увеличить временной интервал, на основании которого 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)

forkManaged следит за тем, чтобы количество одновременно запущенных управляемых потоков не превышало maxThreadsCount. Все работает нормально, пока нет большой нагрузки. При большой нагрузке RTS выбрасывает исключение. Я думаю, что при большой нагрузке, при жесткой параллельной конкуренции за ресурсы, некоторые потоки просто не успевают получить доступ к контексту STM. Поэтому я думаю, что увеличение временного интервала, когда RTS решает выбросить это исключение, может решить проблему.

10
задан Dmitry Bespalov 23 October 2011 в 08:45
поделиться