Control.Monad.Par.Scheds.Direct

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

Documentation

data Sched

Constructors

Sched

Fields

• no :: !Int
• workpool :: WSDeque (Par ())
• rng :: HotVar GenIO
• isMain :: Bool
• sessions :: HotVar [Session]
• idle :: HotVar [MVar Bool]
• scheds :: [Sched]
• activeSessions :: HotVar (Set SessionID)
• sessionCounter :: HotVar SessionID

Instances

MonadReader Sched Par

Defined in Control.Monad.Par.Scheds.DirectInternal

Methods

ask :: Par Sched

local :: (Sched -> Sched) -> Par a -> Par a

reader :: (Sched -> a) -> Par a

data Par a

Instances

Monad Par

Defined in Control.Monad.Par.Scheds.DirectInternal

Methods

(>>=) :: Par a -> (a -> Par b) -> Par b

(>>) :: Par a -> Par b -> Par b

return :: a -> Par a

fail :: String -> Par a

Functor Par

Defined in Control.Monad.Par.Scheds.DirectInternal

Methods

fmap :: (a -> b) -> Par a -> Par b

(<$) :: a -> Par b -> Par a

MonadFix Par

Defined in Control.Monad.Par.Scheds.DirectInternal

Methods

mfix :: (a -> Par a) -> Par a

Applicative Par

Defined in Control.Monad.Par.Scheds.DirectInternal

Methods

pure :: a -> Par a

(<*>) :: Par (a -> b) -> Par a -> Par b

liftA2 :: (a -> b -> c) -> Par a -> Par b -> Par c

(*>) :: Par a -> Par b -> Par b

(<*) :: Par a -> Par b -> Par a

MonadCont Par

Defined in Control.Monad.Par.Scheds.DirectInternal

Methods

callCC :: ((a -> Par b) -> Par a) -> Par a

ParUnsafe IVar Par

Defined in Control.Monad.Par.Scheds.Direct

Methods

unsafePeek :: IVar a -> Par (Maybe a)

unsafeTryPut :: IVar a -> a -> Par a

unsafeParIO :: IO a -> Par a

ParFuture IVar Par

Defined in Control.Monad.Par.Scheds.Direct

Methods

spawn :: NFData a => Par a -> Par (IVar a)

spawn_ :: Par a -> Par (IVar a)

get :: IVar a -> Par a

spawnP :: NFData a => a -> Par (IVar a)

ParIVar IVar Par

Defined in Control.Monad.Par.Scheds.Direct

Methods

fork :: Par () -> Par ()

new :: Par (IVar a)

put :: NFData a => IVar a -> a -> Par ()

put_ :: IVar a -> a -> Par ()

newFull :: NFData a => a -> Par (IVar a)

newFull_ :: a -> Par (IVar a)

MonadReader Sched Par

Defined in Control.Monad.Par.Scheds.DirectInternal

Methods

ask :: Par Sched

local :: (Sched -> Sched) -> Par a -> Par a

reader :: (Sched -> a) -> Par a

newtype IVar a

Constructors

IVar (IORef (IVarContents a))

Instances

ParUnsafe IVar Par

Defined in Control.Monad.Par.Scheds.Direct

Methods

unsafePeek :: IVar a -> Par (Maybe a)

unsafeTryPut :: IVar a -> a -> Par a

unsafeParIO :: IO a -> Par a

ParFuture IVar Par

Defined in Control.Monad.Par.Scheds.Direct

Methods

spawn :: NFData a => Par a -> Par (IVar a)

spawn_ :: Par a -> Par (IVar a)

get :: IVar a -> Par a

spawnP :: NFData a => a -> Par (IVar a)

ParIVar IVar Par

Defined in Control.Monad.Par.Scheds.Direct

Methods

fork :: Par () -> Par ()

new :: Par (IVar a)

put :: NFData a => IVar a -> a -> Par ()

put_ :: IVar a -> a -> Par ()

newFull :: NFData a => a -> Par (IVar a)

newFull_ :: a -> Par (IVar a)

NFData (IVar a)

Defined in Control.Monad.Par.Scheds.Direct

Methods

rnf :: IVar a -> ()

data IVarContents a

Constructors

Full a

Empty

Blocked [a -> IO ()]

runPar :: Par a -> a

runParIO :: Par a -> IO a

new :: Par (IVar a)

Creates a new IVar

get :: IVar a -> Par 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.

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)

fixPar :: (a -> Par a) -> Par a

Take the monadic fixpoint of a Par computation. This is the definition of mfix for Par. Throws FixParException if the result is demanded strictly within the computation.

data FixParException

Constructors

FixParException

Instances

Show FixParException

Defined in Control.Monad.Par.Scheds.DirectInternal

Methods

showsPrec :: Int -> FixParException -> ShowS

show :: FixParException -> String

showList :: [FixParException] -> ShowS

Exception FixParException

Defined in Control.Monad.Par.Scheds.DirectInternal

Methods

toException :: FixParException -> SomeException

fromException :: SomeException -> Maybe FixParException

displayException :: FixParException -> String

Orphan instances

ParUnsafe IVar Par

Methods

unsafePeek :: IVar a -> Par (Maybe a)

unsafeTryPut :: IVar a -> a -> Par a

unsafeParIO :: IO a -> Par a

ParFuture IVar Par

Methods

spawn :: NFData a => Par a -> Par (IVar a)

spawn_ :: Par a -> Par (IVar a)

get :: IVar a -> Par a

spawnP :: NFData a => a -> Par (IVar a)

ParIVar IVar Par

Methods

fork :: Par () -> Par ()

new :: Par (IVar a)

put :: NFData a => IVar a -> a -> Par ()

put_ :: IVar a -> a -> Par ()

newFull :: NFData a => a -> Par (IVar a)

newFull_ :: a -> Par (IVar a)