Control.Concurrent.RCU.GC

Unfenced QSBR w/ Finalizer-Based Fallback Reclamation

Documentation

data SRef s a

Shared references

Instances

MonadRCU (SRef s) (RCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Associated Types

type Reading (RCU s) :: Type -> Type

type Writing (RCU s) :: Type -> Type

type Thread (RCU s) :: Type -> Type

Methods

forking :: RCU s a -> RCU s (Thread (RCU s) a)

joining :: Thread (RCU s) a -> RCU s a

reading :: Reading (RCU s) a -> RCU s a

writing :: Writing (RCU s) a -> RCU s a

MonadWriting (SRef s) (WritingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

writeSRef :: SRef s a -> a -> WritingRCU s ()

synchronize :: WritingRCU s ()

MonadReading (SRef s) (WritingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

readSRef :: SRef s a -> WritingRCU s a

MonadReading (SRef s) (ReadingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

readSRef :: SRef s a -> ReadingRCU s a

MonadNew (SRef s) (RCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

newSRef :: a -> RCU s (SRef s a)

MonadNew (SRef s) (WritingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

newSRef :: a -> WritingRCU s (SRef s a)

MonadNew (SRef s) (ReadingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

newSRef :: a -> ReadingRCU s (SRef s a)

Eq (SRef s a)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

(==) :: SRef s a -> SRef s a -> Bool

(/=) :: SRef s a -> SRef s a -> Bool

data RCU s a

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)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

(>>=) :: RCU s a -> (a -> RCU s b) -> RCU s b

(>>) :: RCU s a -> RCU s b -> RCU s b

return :: a -> RCU s a

Functor (RCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

fmap :: (a -> b) -> RCU s a -> RCU s b

(<$) :: a -> RCU s b -> RCU s a

Applicative (RCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

pure :: a -> RCU s a

(<*>) :: RCU s (a -> b) -> RCU s a -> RCU s b

liftA2 :: (a -> b -> c) -> RCU s a -> RCU s b -> RCU s c

(*>) :: RCU s a -> RCU s b -> RCU s b

(<*) :: RCU s a -> RCU s b -> RCU s a

MonadIO (RCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

liftIO :: IO a -> RCU s a

MonadRCU (SRef s) (RCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Associated Types

type Reading (RCU s) :: Type -> Type

type Writing (RCU s) :: Type -> Type

type Thread (RCU s) :: Type -> Type

Methods

forking :: RCU s a -> RCU s (Thread (RCU s) a)

joining :: Thread (RCU s) a -> RCU s a

reading :: Reading (RCU s) a -> RCU s a

writing :: Writing (RCU s) a -> RCU s a

MonadNew (SRef s) (RCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

newSRef :: a -> RCU s (SRef s a)

type Reading (RCU s)

Defined in Control.Concurrent.RCU.GC.Internal

type Reading (RCU s) = ReadingRCU s

type Writing (RCU s)

Defined in Control.Concurrent.RCU.GC.Internal

type Writing (RCU s) = WritingRCU s

type Thread (RCU s)

Defined in Control.Concurrent.RCU.GC.Internal

type Thread (RCU s) = RCUThread s

runRCU :: (forall s. RCU s a) -> IO a

Run an RCU computation.

class Monad m => MonadNew s m | m -> s where

Minimal complete definition

Nothing

Methods

newSRef :: a -> m (s a)

Build a new shared reference

default newSRef :: (m ~ t n, MonadTrans t, MonadNew s n) => a -> m (s a)

Instances

MonadNew s m => MonadNew s (MaybeT m)

Defined in Control.Concurrent.RCU.Class

Methods

newSRef :: a -> MaybeT m (s a)

MonadNew s m => MonadNew s (IdentityT m)

Defined in Control.Concurrent.RCU.Class

Methods

newSRef :: a -> IdentityT m (s a)

MonadNew s m => MonadNew s (ExceptT e m)

Defined in Control.Concurrent.RCU.Class

Methods

newSRef :: a -> ExceptT e m (s a)

MonadNew s' m => MonadNew s' (StateT s m)

Defined in Control.Concurrent.RCU.Class

Methods

newSRef :: a -> StateT s m (s' a)

MonadNew s' m => MonadNew s' (StateT s m)

Defined in Control.Concurrent.RCU.Class

Methods

newSRef :: a -> StateT s m (s' a)

(MonadNew s m, Monoid w) => MonadNew s (WriterT w m)

Defined in Control.Concurrent.RCU.Class

Methods

newSRef :: a -> WriterT w m (s a)

(MonadNew s m, Monoid w) => MonadNew s (WriterT w m)

Defined in Control.Concurrent.RCU.Class

Methods

newSRef :: a -> WriterT w m (s a)

MonadNew s m => MonadNew s (ReaderT e m)

Defined in Control.Concurrent.RCU.Class

Methods

newSRef :: a -> ReaderT e m (s a)

(MonadNew s' m, Monoid w) => MonadNew s' (RWST r w s m)

Defined in Control.Concurrent.RCU.Class

Methods

newSRef :: a -> RWST r w s m (s' a)

(MonadNew s' m, Monoid w) => MonadNew s' (RWST r w s m)

Defined in Control.Concurrent.RCU.Class

Methods

newSRef :: a -> RWST r w s m (s' a)

MonadNew (SRef s) (RCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

newSRef :: a -> RCU s (SRef s a)

MonadNew (SRef s) (WritingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

newSRef :: a -> WritingRCU s (SRef s a)

MonadNew (SRef s) (ReadingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

newSRef :: a -> ReadingRCU s (SRef s a)

MonadNew (SRef s) (RCU s)

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

newSRef :: a -> RCU s (SRef s a)

MonadNew (SRef s) (WritingRCU s)

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

newSRef :: a -> WritingRCU s (SRef s a)

MonadNew (SRef s) (ReadingRCU s)

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

newSRef :: a -> ReadingRCU s (SRef s a)

class MonadNew s m => MonadReading s m | m -> s where

This is a read-side critical section

Minimal complete definition

Nothing

Methods

readSRef :: s a -> m a

Read a shared reference.

default readSRef :: (m ~ t n, MonadTrans t, MonadReading s n) => s a -> m a

Instances

MonadReading s m => MonadReading s (MaybeT m)

Defined in Control.Concurrent.RCU.Class

Methods

readSRef :: s a -> MaybeT m a

MonadReading s m => MonadReading s (IdentityT m)

Defined in Control.Concurrent.RCU.Class

Methods

readSRef :: s a -> IdentityT m a

MonadReading s m => MonadReading s (ExceptT e m)

Defined in Control.Concurrent.RCU.Class

Methods

readSRef :: s a -> ExceptT e m a

MonadReading s' m => MonadReading s' (StateT s m)

Defined in Control.Concurrent.RCU.Class

Methods

readSRef :: s' a -> StateT s m a

MonadReading s' m => MonadReading s' (StateT s m)

Defined in Control.Concurrent.RCU.Class

Methods

readSRef :: s' a -> StateT s m a

(MonadReading s m, Monoid w) => MonadReading s (WriterT w m)

Defined in Control.Concurrent.RCU.Class

Methods

readSRef :: s a -> WriterT w m a

(MonadReading s m, Monoid w) => MonadReading s (WriterT w m)

Defined in Control.Concurrent.RCU.Class

Methods

readSRef :: s a -> WriterT w m a

MonadReading s m => MonadReading s (ReaderT e m)

Defined in Control.Concurrent.RCU.Class

Methods

readSRef :: s a -> ReaderT e m a

(MonadReading s' m, Monoid w) => MonadReading s' (RWST r w s m)

Defined in Control.Concurrent.RCU.Class

Methods

readSRef :: s' a -> RWST r w s m a

(MonadReading s' m, Monoid w) => MonadReading s' (RWST r w s m)

Defined in Control.Concurrent.RCU.Class

Methods

readSRef :: s' a -> RWST r w s m a

MonadReading (SRef s) (WritingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

readSRef :: SRef s a -> WritingRCU s a

MonadReading (SRef s) (ReadingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

readSRef :: SRef s a -> ReadingRCU s a

MonadReading (SRef s) (WritingRCU s)

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

readSRef :: SRef s a -> WritingRCU s a

MonadReading (SRef s) (ReadingRCU s)

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

readSRef :: SRef s a -> ReadingRCU s a

class MonadReading s m => MonadWriting s m | m -> s where

This is a write-side critical section

Minimal complete definition

Nothing

Methods

writeSRef :: s a -> a -> m ()

Write to a shared reference.

default writeSRef :: (m ~ t n, MonadTrans t, MonadWriting s n) => s a -> a -> m ()

synchronize :: m ()

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!

default synchronize :: (m ~ t n, MonadTrans t, MonadWriting s n) => m ()

Instances

MonadWriting s m => MonadWriting s (MaybeT m)

Defined in Control.Concurrent.RCU.Class

Methods

writeSRef :: s a -> a -> MaybeT m ()

synchronize :: MaybeT m ()

MonadWriting s m => MonadWriting s (ExceptT e m)

Defined in Control.Concurrent.RCU.Class

Methods

writeSRef :: s a -> a -> ExceptT e m ()

synchronize :: ExceptT e m ()

MonadWriting s m => MonadWriting s (IdentityT m)

Defined in Control.Concurrent.RCU.Class

Methods

writeSRef :: s a -> a -> IdentityT m ()

synchronize :: IdentityT m ()

MonadWriting s' m => MonadWriting s' (StateT s m)

Defined in Control.Concurrent.RCU.Class

Methods

writeSRef :: s' a -> a -> StateT s m ()

synchronize :: StateT s m ()

MonadWriting s' m => MonadWriting s' (StateT s m)

Defined in Control.Concurrent.RCU.Class

Methods

writeSRef :: s' a -> a -> StateT s m ()

synchronize :: StateT s m ()

(MonadWriting s m, Monoid w) => MonadWriting s (WriterT w m)

Defined in Control.Concurrent.RCU.Class

Methods

writeSRef :: s a -> a -> WriterT w m ()

synchronize :: WriterT w m ()

(MonadWriting s m, Monoid w) => MonadWriting s (WriterT w m)

Defined in Control.Concurrent.RCU.Class

Methods

writeSRef :: s a -> a -> WriterT w m ()

synchronize :: WriterT w m ()

MonadWriting s m => MonadWriting s (ReaderT e m)

Defined in Control.Concurrent.RCU.Class

Methods

writeSRef :: s a -> a -> ReaderT e m ()

synchronize :: ReaderT e m ()

(MonadWriting s' m, Monoid w) => MonadWriting s' (RWST r w s m)

Defined in Control.Concurrent.RCU.Class

Methods

writeSRef :: s' a -> a -> RWST r w s m ()

synchronize :: RWST r w s m ()

(MonadWriting s' m, Monoid w) => MonadWriting s' (RWST r w s m)

Defined in Control.Concurrent.RCU.Class

Methods

writeSRef :: s' a -> a -> RWST r w s m ()

synchronize :: RWST r w s m ()

MonadWriting (SRef s) (WritingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

writeSRef :: SRef s a -> a -> WritingRCU s ()

synchronize :: WritingRCU s ()

MonadWriting (SRef s) (WritingRCU s)

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

writeSRef :: SRef s a -> a -> WritingRCU s ()

synchronize :: WritingRCU s ()

class (MonadReading s (Reading m), MonadWriting s (Writing m), MonadNew s m) => MonadRCU s m | m -> s where

This is the executor service that can fork, join and execute critical sections.

Associated Types

type Reading m :: * -> *

A read-side critical section

type Writing m :: * -> *

A write-side critical section

type Thread m :: * -> *

Threads we can fork and join

Methods

forking :: m a -> m (Thread m a)

Fork a thread

joining :: Thread m a -> m a

Join a thread

reading :: Reading m a -> m a

Run a read-side critical section

writing :: Writing m a -> m a

Run a write-side critical section

Instances

MonadRCU s m => MonadRCU s (MaybeT m)

Defined in Control.Concurrent.RCU.Class

Associated Types

type Reading (MaybeT m) :: Type -> Type

type Writing (MaybeT m) :: Type -> Type

type Thread (MaybeT m) :: Type -> Type

Methods

forking :: MaybeT m a -> MaybeT m (Thread (MaybeT m) a)

joining :: Thread (MaybeT m) a -> MaybeT m a

reading :: Reading (MaybeT m) a -> MaybeT m a

writing :: Writing (MaybeT m) a -> MaybeT m a

(MonadRCU s m, Monoid e) => MonadRCU s (WriterT e m)

Defined in Control.Concurrent.RCU.Class

Associated Types

type Reading (WriterT e m) :: Type -> Type

type Writing (WriterT e m) :: Type -> Type

type Thread (WriterT e m) :: Type -> Type

Methods

forking :: WriterT e m a -> WriterT e m (Thread (WriterT e m) a)

joining :: Thread (WriterT e m) a -> WriterT e m a

reading :: Reading (WriterT e m) a -> WriterT e m a

writing :: Writing (WriterT e m) a -> WriterT e m a

(MonadRCU s m, Monoid e) => MonadRCU s (WriterT e m)

Defined in Control.Concurrent.RCU.Class

Associated Types

type Reading (WriterT e m) :: Type -> Type

type Writing (WriterT e m) :: Type -> Type

type Thread (WriterT e m) :: Type -> Type

Methods

forking :: WriterT e m a -> WriterT e m (Thread (WriterT e m) a)

joining :: Thread (WriterT e m) a -> WriterT e m a

reading :: Reading (WriterT e m) a -> WriterT e m a

writing :: Writing (WriterT e m) a -> WriterT e m a

MonadRCU s m => MonadRCU s (ExceptT e m)

Defined in Control.Concurrent.RCU.Class

Associated Types

type Reading (ExceptT e m) :: Type -> Type

type Writing (ExceptT e m) :: Type -> Type

type Thread (ExceptT e m) :: Type -> Type

Methods

forking :: ExceptT e m a -> ExceptT e m (Thread (ExceptT e m) a)

joining :: Thread (ExceptT e m) a -> ExceptT e m a

reading :: Reading (ExceptT e m) a -> ExceptT e m a

writing :: Writing (ExceptT e m) a -> ExceptT e m a

MonadRCU s m => MonadRCU s (IdentityT m)

Defined in Control.Concurrent.RCU.Class

Associated Types

type Reading (IdentityT m) :: Type -> Type

type Writing (IdentityT m) :: Type -> Type

type Thread (IdentityT m) :: Type -> Type

Methods

forking :: IdentityT m a -> IdentityT m (Thread (IdentityT m) a)

joining :: Thread (IdentityT m) a -> IdentityT m a

reading :: Reading (IdentityT m) a -> IdentityT m a

writing :: Writing (IdentityT m) a -> IdentityT m a

MonadRCU s m => MonadRCU s (ReaderT e m)

Defined in Control.Concurrent.RCU.Class

Associated Types

type Reading (ReaderT e m) :: Type -> Type

type Writing (ReaderT e m) :: Type -> Type

type Thread (ReaderT e m) :: Type -> Type

Methods

forking :: ReaderT e m a -> ReaderT e m (Thread (ReaderT e m) a)

joining :: Thread (ReaderT e m) a -> ReaderT e m a

reading :: Reading (ReaderT e m) a -> ReaderT e m a

writing :: Writing (ReaderT e m) a -> ReaderT e m a

MonadRCU (SRef s) (RCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Associated Types

type Reading (RCU s) :: Type -> Type

type Writing (RCU s) :: Type -> Type

type Thread (RCU s) :: Type -> Type

Methods

forking :: RCU s a -> RCU s (Thread (RCU s) a)

joining :: Thread (RCU s) a -> RCU s a

reading :: Reading (RCU s) a -> RCU s a

writing :: Writing (RCU s) a -> RCU s a

MonadRCU (SRef s) (RCU s)

Defined in Control.Concurrent.RCU.QSBR.Internal

Associated Types

type Reading (RCU s) :: Type -> Type

type Writing (RCU s) :: Type -> Type

type Thread (RCU s) :: Type -> Type

Methods

forking :: RCU s a -> RCU s (Thread (RCU s) a)

joining :: Thread (RCU s) a -> RCU s a

reading :: Reading (RCU s) a -> RCU s a

writing :: Writing (RCU s) a -> RCU s a

Implementation Details

data ReadingRCU s a

This is the basic read-side critical section for an RCU computation

Instances

Monad (ReadingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

(>>=) :: ReadingRCU s a -> (a -> ReadingRCU s b) -> ReadingRCU s b

(>>) :: ReadingRCU s a -> ReadingRCU s b -> ReadingRCU s b

return :: a -> ReadingRCU s a

Functor (ReadingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

fmap :: (a -> b) -> ReadingRCU s a -> ReadingRCU s b

(<$) :: a -> ReadingRCU s b -> ReadingRCU s a

MonadFail (ReadingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

fail :: String -> ReadingRCU s a

Applicative (ReadingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

pure :: a -> ReadingRCU s a

(<*>) :: ReadingRCU s (a -> b) -> ReadingRCU s a -> ReadingRCU s b

liftA2 :: (a -> b -> c) -> ReadingRCU s a -> ReadingRCU s b -> ReadingRCU s c

(*>) :: ReadingRCU s a -> ReadingRCU s b -> ReadingRCU s b

(<*) :: ReadingRCU s a -> ReadingRCU s b -> ReadingRCU s a

Alternative (ReadingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

empty :: ReadingRCU s a

(<|>) :: ReadingRCU s a -> ReadingRCU s a -> ReadingRCU s a

some :: ReadingRCU s a -> ReadingRCU s [a]

many :: ReadingRCU s a -> ReadingRCU s [a]

MonadPlus (ReadingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

mzero :: ReadingRCU s a

mplus :: ReadingRCU s a -> ReadingRCU s a -> ReadingRCU s a

MonadReading (SRef s) (ReadingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

readSRef :: SRef s a -> ReadingRCU s a

MonadNew (SRef s) (ReadingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

newSRef :: a -> ReadingRCU s (SRef s a)

data WritingRCU s a

This is the basic write-side critical section for an RCU computation

Instances

Monad (WritingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

(>>=) :: WritingRCU s a -> (a -> WritingRCU s b) -> WritingRCU s b

(>>) :: WritingRCU s a -> WritingRCU s b -> WritingRCU s b

return :: a -> WritingRCU s a

Functor (WritingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

fmap :: (a -> b) -> WritingRCU s a -> WritingRCU s b

(<$) :: a -> WritingRCU s b -> WritingRCU s a

MonadFail (WritingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

fail :: String -> WritingRCU s a

Applicative (WritingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

pure :: a -> WritingRCU s a

(<*>) :: WritingRCU s (a -> b) -> WritingRCU s a -> WritingRCU s b

liftA2 :: (a -> b -> c) -> WritingRCU s a -> WritingRCU s b -> WritingRCU s c

(*>) :: WritingRCU s a -> WritingRCU s b -> WritingRCU s b

(<*) :: WritingRCU s a -> WritingRCU s b -> WritingRCU s a

Alternative (WritingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

empty :: WritingRCU s a

(<|>) :: WritingRCU s a -> WritingRCU s a -> WritingRCU s a

some :: WritingRCU s a -> WritingRCU s [a]

many :: WritingRCU s a -> WritingRCU s [a]

MonadPlus (WritingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

mzero :: WritingRCU s a

mplus :: WritingRCU s a -> WritingRCU s a -> WritingRCU s a

MonadWriting (SRef s) (WritingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

writeSRef :: SRef s a -> a -> WritingRCU s ()

synchronize :: WritingRCU s ()

MonadReading (SRef s) (WritingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

readSRef :: SRef s a -> WritingRCU s a

MonadNew (SRef s) (WritingRCU s)

Defined in Control.Concurrent.RCU.GC.Internal

Methods

newSRef :: a -> WritingRCU s (SRef s a)

data RCUThread s a

This is a basic RCU thread. It may be embellished when running in a more exotic context.