Hedgehog.Internal.Queue

Documentation

newtype TaskIndex

Constructors

TaskIndex Int

Instances

Enum TaskIndex

Methods

succ :: TaskIndex -> TaskIndex

pred :: TaskIndex -> TaskIndex

toEnum :: Int -> TaskIndex

fromEnum :: TaskIndex -> Int

enumFrom :: TaskIndex -> [TaskIndex]

enumFromThen :: TaskIndex -> TaskIndex -> [TaskIndex]

enumFromTo :: TaskIndex -> TaskIndex -> [TaskIndex]

enumFromThenTo :: TaskIndex -> TaskIndex -> TaskIndex -> [TaskIndex]

Eq TaskIndex

Methods

(==) :: TaskIndex -> TaskIndex -> Bool

(/=) :: TaskIndex -> TaskIndex -> Bool

Num TaskIndex

Methods

(+) :: TaskIndex -> TaskIndex -> TaskIndex

(-) :: TaskIndex -> TaskIndex -> TaskIndex

(*) :: TaskIndex -> TaskIndex -> TaskIndex

negate :: TaskIndex -> TaskIndex

abs :: TaskIndex -> TaskIndex

signum :: TaskIndex -> TaskIndex

fromInteger :: Integer -> TaskIndex

Ord TaskIndex

Methods

compare :: TaskIndex -> TaskIndex -> Ordering

(<) :: TaskIndex -> TaskIndex -> Bool

(<=) :: TaskIndex -> TaskIndex -> Bool

(>) :: TaskIndex -> TaskIndex -> Bool

(>=) :: TaskIndex -> TaskIndex -> Bool

max :: TaskIndex -> TaskIndex -> TaskIndex

min :: TaskIndex -> TaskIndex -> TaskIndex

newtype TasksRemaining

Constructors

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 ()

Update the number of capabilities but never set it lower than it already is.