Copyright	(C) 2015 Edward Kmett and Ted Cooper
License	BSD-style (see the file LICENSE)
Maintainer	Edward Kmett <[email protected]>, Ted Cooper <[email protected]>
Stability	experimental
Portability	non-portable
Safe Haskell	None
Language	Haskell2010

Control.Concurrent.RCU.QSBR.Internal

Description

QSBR-based RCU

Synopsis

newtype SRef s a = SRef {
- unSRef :: IORef a
}
data RCUThread s a = RCUThread {
- rcuThreadId :: !ThreadId
- rcuThreadVar :: !(MVar a)
}
newtype RCU s a = RCU {
- unRCU :: RCUState -> IO a
}
runRCU :: (forall s. RCU s a) -> IO a
runOnRCU :: Int -> (forall s. RCU s a) -> IO a
newtype ReadingRCU s a = ReadingRCU {
- runReadingRCU :: RCUState -> IO a
}
newtype WritingRCU s a = WritingRCU {
- runWritingRCU :: RCUState -> IO a
}
data RCUState = RCUState {
- rcuStateGlobalCounter :: !Counter
- rcuStateThreadCountersR :: !(IORef [Counter])
- rcuStateThreadCountersLockV :: !(MVar ())
- rcuStateWriterLockV :: !(MVar ())
- rcuStateMyCounter :: !Counter
- rcuStatePinned :: !(Maybe Int)
}

Documentation

newtype SRef s a Source #

Shared references

Constructors

SRef
Fields unSRef :: IORef a

Instances

Instances details

MonadNew (SRef s) (RCU s) Source #

Instance details

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

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

MonadNew (SRef s) (ReadingRCU s) Source #

Instance details

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

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

MonadNew (SRef s) (WritingRCU s) Source #

Instance details

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

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

MonadRCU (SRef s) (RCU s) Source #

Instance details

Defined in Control.Concurrent.RCU.QSBR.Internal

Associated Types

type Reading (RCU s)
Instance details Defined in Control.Concurrent.RCU.QSBR.Internal type Reading (RCU s) = ReadingRCU s
type Writing (RCU s)
Instance details Defined in Control.Concurrent.RCU.QSBR.Internal type Writing (RCU s) = WritingRCU s
type Thread (RCU s)
Instance details Defined in Control.Concurrent.RCU.QSBR.Internal type Thread (RCU s) = RCUThread s

Methods

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

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

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

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

MonadReading (SRef s) (ReadingRCU s) Source #

Instance details

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

readSRef :: SRef s a -> ReadingRCU s a Source #

MonadReading (SRef s) (WritingRCU s) Source #

Instance details

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

readSRef :: SRef s a -> WritingRCU s a Source #

MonadWriting (SRef s) (WritingRCU s) Source #

Instance details

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

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

synchronize :: WritingRCU s () Source #

Eq (SRef s a) Source #

Instance details

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 Source #

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

Constructors

RCU
Fields unRCU :: RCUState -> IO a

Instances

Instances details

MonadIO (RCU s) Source #

Instance details

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

liftIO :: IO a -> RCU s a #

Applicative (RCU s) Source #

Instance details

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 #

Functor (RCU s) Source #

Instance details

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

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

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

Monad (RCU s) Source #

Instance details

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 #

MonadNew (SRef s) (RCU s) Source #

Instance details

Defined in Control.Concurrent.RCU.QSBR.Internal

Methods

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

MonadRCU (SRef s) (RCU s) Source #

Instance details

Defined in Control.Concurrent.RCU.QSBR.Internal

Associated Types

type Reading (RCU s)
Instance details Defined in Control.Concurrent.RCU.QSBR.Internal type Reading (RCU s) = ReadingRCU s
type Writing (RCU s)
Instance details Defined in Control.Concurrent.RCU.QSBR.Internal type Writing (RCU s) = WritingRCU s
type Thread (RCU s)
Instance details Defined in Control.Concurrent.RCU.QSBR.Internal type Thread (RCU s) = RCUThread s

Methods

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

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

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

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

type Reading (RCU s) Source #

Instance details

Defined in Control.Concurrent.RCU.QSBR.Internal

type Reading (RCU s) = ReadingRCU s

type Thread (RCU s) Source #

Instance details

Defined in Control.Concurrent.RCU.QSBR.Internal

type Thread (RCU s) = RCUThread s

type Writing (RCU s) Source #

Instance details

Defined in Control.Concurrent.RCU.QSBR.Internal

type Writing (RCU s) = WritingRCU s

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

Run an RCU computation.

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

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

newtype ReadingRCU s a Source #

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

Constructors

ReadingRCU
Fields runReadingRCU :: RCUState -> IO a

Instances

Instances details

MonadFail (ReadingRCU s) Source #
Instance details Defined in Control.Concurrent.RCU.QSBR.Internal Methods fail :: String -> ReadingRCU s a #
Alternative (ReadingRCU s) Source #
Instance details 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] #
Applicative (ReadingRCU s) Source #
Instance details 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 #
Functor (ReadingRCU s) Source #
Instance details Defined in Control.Concurrent.RCU.QSBR.Internal Methods fmap :: (a -> b) -> ReadingRCU s a -> ReadingRCU s b # (<$) :: a -> ReadingRCU s b -> ReadingRCU s a #
Monad (ReadingRCU s) Source #
Instance details 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 #
MonadPlus (ReadingRCU s) Source #
Instance details Defined in Control.Concurrent.RCU.QSBR.Internal Methods mzero :: ReadingRCU s a # mplus :: ReadingRCU s a -> ReadingRCU s a -> ReadingRCU s a #
MonadNew (SRef s) (ReadingRCU s) Source #
Instance details Defined in Control.Concurrent.RCU.QSBR.Internal Methods newSRef :: a -> ReadingRCU s (SRef s a) Source #
MonadReading (SRef s) (ReadingRCU s) Source #
Instance details Defined in Control.Concurrent.RCU.QSBR.Internal Methods readSRef :: SRef s a -> ReadingRCU s a Source #

newtype WritingRCU s a Source #

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

Constructors

WritingRCU
Fields runWritingRCU :: RCUState -> IO a

Instances

Instances details

MonadFail (WritingRCU s) Source #
Instance details Defined in Control.Concurrent.RCU.QSBR.Internal Methods fail :: String -> WritingRCU s a #
Alternative (WritingRCU s) Source #
Instance details 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] #
Applicative (WritingRCU s) Source #
Instance details 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 #
Functor (WritingRCU s) Source #
Instance details Defined in Control.Concurrent.RCU.QSBR.Internal Methods fmap :: (a -> b) -> WritingRCU s a -> WritingRCU s b # (<$) :: a -> WritingRCU s b -> WritingRCU s a #
Monad (WritingRCU s) Source #
Instance details 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 #
MonadPlus (WritingRCU s) Source #
Instance details Defined in Control.Concurrent.RCU.QSBR.Internal Methods mzero :: WritingRCU s a # mplus :: WritingRCU s a -> WritingRCU s a -> WritingRCU s a #
MonadNew (SRef s) (WritingRCU s) Source #
Instance details Defined in Control.Concurrent.RCU.QSBR.Internal Methods newSRef :: a -> WritingRCU s (SRef s a) Source #
MonadReading (SRef s) (WritingRCU s) Source #
Instance details Defined in Control.Concurrent.RCU.QSBR.Internal Methods readSRef :: SRef s a -> WritingRCU s a Source #
MonadWriting (SRef s) (WritingRCU s) Source #
Instance details Defined in Control.Concurrent.RCU.QSBR.Internal Methods writeSRef :: SRef s a -> a -> WritingRCU s () Source # synchronize :: WritingRCU s () Source #

data RCUState Source #

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)