Safe Haskell | None |
---|---|
Language | Haskell98 |
A scheduler for the Par monad based on directly performing IO actions when Par methods are called (i.e. without using a lazy trace data structure).
Synopsis
- data Sched = Sched {}
- data Par a
- newtype IVar a = IVar (IORef (IVarContents a))
- data IVarContents a
- runPar :: Par a -> a
- runParIO :: Par a -> IO a
- new :: Par (IVar a)
- get :: IVar a -> Par a
- put_ :: IVar a -> a -> Par ()
- fork :: Par () -> Par ()
- newFull :: NFData a => a -> Par (IVar a)
- newFull_ :: a -> Par (IVar a)
- put :: NFData a => IVar a -> a -> Par ()
- spawn :: NFData a => Par a -> Par (IVar a)
- spawn_ :: Par a -> Par (IVar a)
- spawnP :: NFData a => a -> Par (IVar a)
- spawn1_ :: (a -> Par b) -> a -> Par (IVar b)
Documentation
Instances
Monad Par # | |
Functor Par # | |
Applicative Par # | |
MonadCont Par # | |
ParUnsafe IVar Par # | |
Defined in Control.Monad.Par.Scheds.Direct unsafePeek :: IVar a -> Par (Maybe a) # unsafeTryPut :: IVar a -> a -> Par a # unsafeParIO :: IO a -> Par a # | |
ParFuture IVar Par # | |
ParIVar IVar Par # | |
MonadReader Sched Par # | |
IVar (IORef (IVarContents a)) |
Read the value in an IVar
. The get
operation can only return when the
value has been written by a prior or parallel put
to the same
IVar
.
put_ :: IVar a -> a -> Par () #
put_
is a version of put
that is head-strict rather than fully-strict.
In this scheduler, puts immediately execute woken work in the current thread.