Copyright | (C) 2015 Edward Kmett Paul Khuong and Ted Cooper |
---|---|
License | BSD-style (see the file LICENSE) |
Maintainer | Edward Kmett <ekmett@gmail.com> Ted Cooper <anthezium@gmail.com> |
Stability | experimental |
Portability | non-portable |
Safe Haskell | Trustworthy |
Language | Haskell2010 |
Unfenced QSBR w/ Finalizer-Based Fallback Reclamation
Synopsis
- data SRef s a
- data RCU s a
- runRCU :: (forall s. RCU s a) -> IO a
- class Monad m => MonadNew s m | m -> s where
- class MonadNew s m => MonadReading s m | m -> s where
- class MonadReading s m => MonadWriting s m | m -> s where
- class (MonadReading s (Reading m), MonadWriting s (Writing m), MonadNew s m) => MonadRCU s m | m -> s where
- data ReadingRCU s a
- data WritingRCU s a
- data RCUThread s a
Documentation
Shared references
Instances
MonadRCU (SRef s) (RCU s) Source # | |
MonadWriting (SRef s) (WritingRCU s) Source # | |
Defined in Control.Concurrent.RCU.GC.Internal writeSRef :: SRef s a -> a -> WritingRCU s () Source # synchronize :: WritingRCU s () Source # | |
MonadReading (SRef s) (WritingRCU s) Source # | |
Defined in Control.Concurrent.RCU.GC.Internal readSRef :: SRef s a -> WritingRCU s a Source # | |
MonadReading (SRef s) (ReadingRCU s) Source # | |
Defined in Control.Concurrent.RCU.GC.Internal readSRef :: SRef s a -> ReadingRCU s a Source # | |
MonadNew (SRef s) (RCU s) Source # | |
MonadNew (SRef s) (WritingRCU s) Source # | |
Defined in Control.Concurrent.RCU.GC.Internal newSRef :: a -> WritingRCU s (SRef s a) Source # | |
MonadNew (SRef s) (ReadingRCU s) Source # | |
Defined in Control.Concurrent.RCU.GC.Internal newSRef :: a -> ReadingRCU s (SRef s a) Source # | |
Eq (SRef s a) Source # | |
This is an RCU computation. It can use forking
and joining
to form
new threads, and then you can use reading
and writing
to run classic
read-side and write-side RCU computations. Writers are
serialized using an MVar, readers are able to proceed while writers are
updating.
Instances
Monad (RCU s) Source # | |
Functor (RCU s) Source # | |
Applicative (RCU s) Source # | |
MonadIO (RCU s) Source # | |
Defined in Control.Concurrent.RCU.GC.Internal | |
MonadRCU (SRef s) (RCU s) Source # | |
MonadNew (SRef s) (RCU s) Source # | |
type Reading (RCU s) Source # | |
Defined in Control.Concurrent.RCU.GC.Internal | |
type Writing (RCU s) Source # | |
Defined in Control.Concurrent.RCU.GC.Internal | |
type Thread (RCU s) Source # | |
Defined in Control.Concurrent.RCU.GC.Internal |
class Monad m => MonadNew s m | m -> s where Source #
newSRef :: a -> m (s a) Source #
Build a new shared reference
newSRef :: (m ~ t n, MonadTrans t, MonadNew s n) => a -> m (s a) Source #
Build a new shared reference
Instances
class MonadNew s m => MonadReading s m | m -> s where Source #
This is a read-side critical section
readSRef :: s a -> m a Source #
Read a shared reference.
readSRef :: (m ~ t n, MonadTrans t, MonadReading s n) => s a -> m a Source #
Read a shared reference.
Instances
class MonadReading s m => MonadWriting s m | m -> s where Source #
This is a write-side critical section
writeSRef :: s a -> a -> m () Source #
Write to a shared reference.
writeSRef :: (m ~ t n, MonadTrans t, MonadWriting s n) => s a -> a -> m () Source #
Write to a shared reference.
synchronize :: m () Source #
Synchronize with other writers.
No other writer can straddle this time bound. It will either see writes from before, or writes after, but never some of both!
synchronize :: (m ~ t n, MonadTrans t, MonadWriting s n) => m () Source #
Synchronize with other writers.
No other writer can straddle this time bound. It will either see writes from before, or writes after, but never some of both!
Instances
class (MonadReading s (Reading m), MonadWriting s (Writing m), MonadNew s m) => MonadRCU s m | m -> s where Source #
This is the executor service that can fork, join and execute critical sections.
type Reading m :: * -> * Source #
A read-side critical section
type Writing m :: * -> * Source #
A write-side critical section
type Thread m :: * -> * Source #
Threads we can fork and join
forking :: m a -> m (Thread m a) Source #
Fork a thread
joining :: Thread m a -> m a Source #
Join a thread
reading :: Reading m a -> m a Source #
Run a read-side critical section
writing :: Writing m a -> m a Source #
Run a write-side critical section
Instances
MonadRCU s m => MonadRCU s (MaybeT m) Source # | |
(MonadRCU s m, Monoid e) => MonadRCU s (WriterT e m) Source # | |
(MonadRCU s m, Monoid e) => MonadRCU s (WriterT e m) Source # | |
MonadRCU s m => MonadRCU s (ExceptT e m) Source # | |
MonadRCU s m => MonadRCU s (IdentityT m) Source # | |
MonadRCU s m => MonadRCU s (ReaderT e m) Source # | |
MonadRCU (SRef s) (RCU s) Source # | |
MonadRCU (SRef s) (RCU s) Source # | |
Implementation Details
data ReadingRCU s a Source #
This is the basic read-side critical section for an RCU computation
Instances
data WritingRCU s a Source #
This is the basic write-side critical section for an RCU computation