Control.Concurrent.RCU.QSBR.Internal

QSBR-based RCU

Documentation

newtype SRef s a

Shared references

Constructors

SRef

Fields

• unSRef :: IORef a

Instances

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

MonadWriting (SRef s) (WritingRCU s)

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

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

synchronize :: WritingRCU s ()

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

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)

Eq (SRef s a)

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

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

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

data RCUThread s a

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

Constructors

RCUThread

Fields

• rcuThreadId :: !ThreadId
• rcuThreadVar :: !(MVar a)

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

Constructors

RCU

Fields

• unRCU :: RCUState -> IO a

Instances

Monad (RCU s)

Defined in Control.Concurrent.RCU.QSBR.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.QSBR.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.QSBR.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.QSBR.Internal

Methods

liftIO :: IO 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

MonadNew (SRef s) (RCU s)

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

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

type Reading (RCU s)

Defined in Control.Concurrent.RCU.QSBR.Internal

type Reading (RCU s) = ReadingRCU s

type Writing (RCU s)

Defined in Control.Concurrent.RCU.QSBR.Internal

type Writing (RCU s) = WritingRCU s

type Thread (RCU s)

Defined in Control.Concurrent.RCU.QSBR.Internal

type Thread (RCU s) = RCUThread s

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

Run an RCU computation.

runOnRCU :: Int -> (forall s. RCU s a) -> IO a

Run an RCU computation in a thread pinned to a particular core.

newtype ReadingRCU s a

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

Constructors

ReadingRCU

Fields

• runReadingRCU :: RCUState -> IO a

Instances

Monad (ReadingRCU s)

Defined in Control.Concurrent.RCU.QSBR.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.QSBR.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.QSBR.Internal

Methods

fail :: String -> ReadingRCU s a

Applicative (ReadingRCU s)

Defined in Control.Concurrent.RCU.QSBR.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.QSBR.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.QSBR.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.QSBR.Internal

Methods

readSRef :: SRef s a -> ReadingRCU s a

MonadNew (SRef s) (ReadingRCU s)

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

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

newtype WritingRCU s a

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

Constructors

WritingRCU

Fields

• runWritingRCU :: RCUState -> IO a

Instances

Monad (WritingRCU s)

Defined in Control.Concurrent.RCU.QSBR.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.QSBR.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.QSBR.Internal

Methods

fail :: String -> WritingRCU s a

Applicative (WritingRCU s)

Defined in Control.Concurrent.RCU.QSBR.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.QSBR.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.QSBR.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.QSBR.Internal

Methods

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

synchronize :: WritingRCU s ()

MonadReading (SRef s) (WritingRCU s)

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

readSRef :: SRef s a -> WritingRCU s a

MonadNew (SRef s) (WritingRCU s)

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

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

data RCUState

State for an RCU computation.

Constructors

RCUState

Fields

• rcuStateGlobalCounter :: !Counter

  Global state

• rcuStateThreadCountersR :: !(IORef [Counter])
• rcuStateThreadCountersLockV :: !(MVar ())
• rcuStateWriterLockV :: !(MVar ())
• rcuStateMyCounter :: !Counter

  Thread state

• rcuStatePinned :: !(Maybe Int)