Safe Haskell | None |
---|---|
Language | Haskell2010 |
Synopsis
- newtype TaskIndex = TaskIndex Int
- newtype TasksRemaining = TasksRemaining Int
- runTasks :: WorkerCount -> [a] -> (TasksRemaining -> TaskIndex -> a -> IO b) -> (b -> IO ()) -> (b -> IO ()) -> (b -> IO c) -> IO [c]
- finalizeTask :: MonadIO m => MVar (TaskIndex, Map TaskIndex (IO ())) -> TaskIndex -> IO () -> m ()
- runActiveFinalizers :: MonadIO m => MVar (TaskIndex, Map TaskIndex (IO ())) -> m ()
- dequeueMVar :: MVar [(TaskIndex, a)] -> (TasksRemaining -> TaskIndex -> a -> IO b) -> IO (Maybe (TaskIndex, b))
- updateNumCapabilities :: WorkerCount -> IO ()
Documentation
Instances
Enum TaskIndex Source # | |
Defined in Hedgehog.Internal.Queue succ :: TaskIndex -> TaskIndex # pred :: TaskIndex -> TaskIndex # fromEnum :: TaskIndex -> Int # enumFrom :: TaskIndex -> [TaskIndex] # enumFromThen :: TaskIndex -> TaskIndex -> [TaskIndex] # enumFromTo :: TaskIndex -> TaskIndex -> [TaskIndex] # enumFromThenTo :: TaskIndex -> TaskIndex -> TaskIndex -> [TaskIndex] # | |
Eq TaskIndex Source # | |
Num TaskIndex Source # | |
Defined in Hedgehog.Internal.Queue | |
Ord TaskIndex Source # | |
Defined in Hedgehog.Internal.Queue |
newtype TasksRemaining Source #
runTasks :: WorkerCount -> [a] -> (TasksRemaining -> TaskIndex -> a -> IO b) -> (b -> IO ()) -> (b -> IO ()) -> (b -> IO c) -> IO [c] Source #
finalizeTask :: MonadIO m => MVar (TaskIndex, Map TaskIndex (IO ())) -> TaskIndex -> IO () -> m () Source #
dequeueMVar :: MVar [(TaskIndex, a)] -> (TasksRemaining -> TaskIndex -> a -> IO b) -> IO (Maybe (TaskIndex, b)) Source #
updateNumCapabilities :: WorkerCount -> IO () Source #
Update the number of capabilities but never set it lower than it already is.