Safe Haskell | None |
---|---|
Language | Haskell98 |
Hedgehog.Internal.Queue
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 Methods succ :: TaskIndex -> TaskIndex Source # pred :: TaskIndex -> TaskIndex Source # toEnum :: Int -> TaskIndex Source # fromEnum :: TaskIndex -> Int Source # enumFrom :: TaskIndex -> [TaskIndex] Source # enumFromThen :: TaskIndex -> TaskIndex -> [TaskIndex] Source # enumFromTo :: TaskIndex -> TaskIndex -> [TaskIndex] Source # enumFromThenTo :: TaskIndex -> TaskIndex -> TaskIndex -> [TaskIndex] Source # | |
Eq TaskIndex Source # | |
Num TaskIndex Source # | |
Defined in Hedgehog.Internal.Queue Methods (+) :: TaskIndex -> TaskIndex -> TaskIndex Source # (-) :: TaskIndex -> TaskIndex -> TaskIndex Source # (*) :: TaskIndex -> TaskIndex -> TaskIndex Source # negate :: TaskIndex -> TaskIndex Source # abs :: TaskIndex -> TaskIndex Source # signum :: TaskIndex -> TaskIndex Source # fromInteger :: Integer -> TaskIndex Source # | |
Ord TaskIndex Source # | |
Defined in Hedgehog.Internal.Queue |
newtype TasksRemaining Source #
Constructors
TasksRemaining Int |
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.