Language.Embedded.Concurrent.CMD

Documentation

type TID = VarId

data ThreadId

Constructors

TIDEval ThreadId (Flag ())

TIDComp TID

Instances

Show ThreadId

type CID = VarId

type ChanBound = Word16

Maximum number of elements in some bounded channel.

data Chan t a

A bounded channel.

Constructors

ChanEval (BoundedChan a) (IORef Bool) (IORef Bool)

ChanComp CID

data ThreadCMD fs a where

Constructors

ForkWithId :: (ThreadId -> prog ()) -> ThreadCMD (Param3 prog exp pred) ThreadId

Kill :: ThreadId -> ThreadCMD (Param3 prog exp pred) ()

Wait :: ThreadId -> ThreadCMD (Param3 prog exp pred) ()

Instances

HFunctor * * ((,) k ((,) k *)) (ThreadCMD k k)

HBifunctor * k ((,) k *) (ThreadCMD (k -> *) k)

(:<:) ((,) (* -> *) ((,) (k -> *) ((,) k1 *))) * (ThreadCMD (k -> *) k1) instr => Reexpressible k ((,) k *) (ThreadCMD (k -> *) k) instr

InterpBi ((,) k *) * (ThreadCMD (* -> *) k) IO (Param1 k pred)

data ChanCMD fs a where

Constructors

NewChan :: pred a => exp ChanBound -> ChanCMD (Param3 prog exp pred) (Chan t a)

ReadChan :: pred a => Chan t a -> ChanCMD (Param3 prog exp pred) (Val a)

WriteChan :: pred a => Chan t a -> exp a -> ChanCMD (Param3 prog exp pred) (Val Bool)

CloseChan :: Chan Closeable a -> ChanCMD (Param3 prog exp pred) ()

ReadOK :: Chan Closeable a -> ChanCMD (Param3 prog exp pred) (Val Bool)

Instances

HFunctor k * ((,) (* -> *) ((,) (* -> Constraint) *)) (ChanCMD (k -> *))

HBifunctor * * ((,) (* -> Constraint) *) (ChanCMD (* -> *))

(:<:) ((,) (* -> *) ((,) (* -> *) ((,) (* -> Constraint) *))) * (ChanCMD (* -> *)) instr => Reexpressible * ((,) (* -> Constraint) *) (ChanCMD (* -> *)) instr

InterpBi ((,) (* -> Constraint) *) * (ChanCMD (* -> *)) IO (Param1 (* -> Constraint) pred)

data Closeable

data Uncloseable