module Language.Embedded.Concurrent (
ThreadId (..),
ChanBound, Chan (..),
ThreadCMD,
ChanCMD,
Closeable, Uncloseable,
fork, forkWithId, asyncKillThread, killThread, waitThread,
newChan, newCloseableChan, readChan, writeChan,
closeChan, lastChanReadOK,
) where
import Control.Monad.Operational.Higher
import Language.Embedded.Expression
import Language.Embedded.Concurrent.CMD
import Language.Embedded.Concurrent.Backend.C ()
fork :: (ThreadCMD :<: instr)
=> ProgramT instr m ()
-> ProgramT instr m ThreadId
fork = forkWithId . const
forkWithId :: (ThreadCMD :<: instr)
=> (ThreadId -> ProgramT instr m ())
-> ProgramT instr m ThreadId
forkWithId = singleton . inj . ForkWithId
asyncKillThread :: (ThreadCMD :<: instr) => ThreadId -> ProgramT instr m ()
asyncKillThread = singleton . inj . Kill
killThread :: (ThreadCMD :<: instr, Monad m) => ThreadId -> ProgramT instr m ()
killThread t = do
singleton . inj $ Kill t
waitThread t
waitThread :: (ThreadCMD :<: instr) => ThreadId -> ProgramT instr m ()
waitThread = singleton . inj . Wait
newChan :: (VarPred (IExp instr) a, ChanCMD (IExp instr) :<: instr)
=> IExp instr ChanBound
-> ProgramT instr m (Chan Uncloseable a)
newChan = singleE . NewChan
newCloseableChan :: (VarPred (IExp instr) a, ChanCMD (IExp instr) :<: instr)
=> IExp instr ChanBound
-> ProgramT instr m (Chan Closeable a)
newCloseableChan = singleE . NewChan
readChan :: (VarPred (IExp instr) a, ChanCMD (IExp instr) :<: instr)
=> Chan t a
-> ProgramT instr m (IExp instr a)
readChan = singleE . ReadChan
writeChan :: (VarPred (IExp instr) a,
VarPred (IExp instr) Bool,
ChanCMD (IExp instr) :<: instr)
=> Chan t a
-> IExp instr a
-> ProgramT instr m (IExp instr Bool)
writeChan c = singleE . WriteChan c
lastChanReadOK :: (VarPred (IExp instr) Bool, ChanCMD (IExp instr) :<: instr)
=> Chan Closeable a
-> ProgramT instr m (IExp instr Bool)
lastChanReadOK = singleE . ReadOK
closeChan :: (ChanCMD (IExp instr) :<: instr)
=> Chan Closeable a
-> ProgramT instr m ()
closeChan = singleE . CloseChan