Control.Concurrent.STM.Promise.Workers

Evaluating promises in parallel

Documentation

workers :: Maybe Int -> Int -> [Promise a] -> IO ()

Evaluate these promises on n processors, maybe using a timeout in microseconds.

worker :: Maybe Int -> TChan (Promise a) -> IO ()

Evaluates a channel of promises, maybe using a timeout in microseconds. Stops when the channel is empty.

evaluatePromise :: Maybe Int -> Promise a -> IO ()

Evaluates a single promise (in the calling thread), maybe using a timeout in microseconds.