Safe Haskell	Safe-Inferred
Language	Haskell2010

Effectful.Ki

Contents

Effect
Handlers
Core API
Extended API
- Thread options
- Byte count
STM re-export

Synopsis

data StructuredConcurrency :: Effect
runStructuredConcurrency :: IOE :> es => Eff (StructuredConcurrency ': es) a -> Eff es a
data Scope
data Thread a
scoped :: StructuredConcurrency :> es => (Scope -> Eff es a) -> Eff es a
fork :: StructuredConcurrency :> es => Scope -> Eff es a -> Eff es (Thread a)
forkTry :: Exception e => StructuredConcurrency :> es => Scope -> Eff es a -> Eff es (Thread (Either e a))
await :: Thread a -> STM a
awaitAll :: Scope -> STM ()
fork_ :: StructuredConcurrency :> es => Scope -> Eff es Void -> Eff es ()
forkWith :: StructuredConcurrency :> es => Scope -> ThreadOptions -> Eff es a -> Eff es (Thread a)
forkWith_ :: StructuredConcurrency :> es => Scope -> ThreadOptions -> Eff es Void -> Eff es ()
forkTryWith :: Exception e => Scope -> StructuredConcurrency :> es => ThreadOptions -> Eff es a -> Eff es (Thread (Either e a))
data ThreadOptions = ThreadOptions {
- affinity :: ThreadAffinity
- allocationLimit :: Maybe ByteCount
- label :: String
- maskingState :: MaskingState
}
defaultThreadOptions :: ThreadOptions
data ThreadAffinity
- = Unbound
- | Capability Int
- | OsThread
data ByteCount
kilobytes :: Natural -> ByteCount
megabytes :: Natural -> ByteCount
atomically :: StructuredConcurrency :> es => STM a -> Eff es a
newTVarIO :: StructuredConcurrency :> es => a -> Eff es (TVar a)
newTMVarIO :: StructuredConcurrency :> es => a -> Eff es (TMVar a)
newEmptyTMVarIO :: StructuredConcurrency :> es => Eff es (TMVar a)

Effect

data StructuredConcurrency :: Effect Source #

Instances

Instances details

type DispatchOf StructuredConcurrency Source #
Instance details Defined in Effectful.Ki type DispatchOf StructuredConcurrency = 'Static 'WithSideEffects
data StaticRep StructuredConcurrency Source #
Instance details Defined in Effectful.Ki data StaticRep StructuredConcurrency = StructuredConcurrency

Handlers

runStructuredConcurrency :: IOE :> es => Eff (StructuredConcurrency ': es) a -> Eff es a Source #

Run the StructuredConcurrency effect.

Core API

data Scope #

A scope.

👉 Details

Expand

A scope delimits the lifetime of all threads created within it.
A scope is only valid during the callback provided to scoped.
The thread that creates a scope is considered the parent of all threads created within it.
All threads created within a scope can be awaited together (see awaitAll).
All threads created within a scope are terminated when the scope closes.

data Thread a #

A thread.

👉 Details

Expand

A thread's lifetime is delimited by the scope in which it was created.
The thread that creates a scope is considered the parent of all threads created within it.
If an exception is raised in a child thread, the child either propagates the exception to its parent (see fork), or returns the exception as a value (see forkTry).
All threads created within a scope are terminated when the scope closes.

Instances

Instances details

Functor Thread
Instance details Defined in Ki.Internal.Thread Methods fmap :: (a -> b) -> Thread a -> Thread b # (<$) :: a -> Thread b -> Thread a #
Eq (Thread a)
Instance details Defined in Ki.Internal.Thread Methods (==) :: Thread a -> Thread a -> Bool # (/=) :: Thread a -> Thread a -> Bool #
Ord (Thread a)
Instance details Defined in Ki.Internal.Thread Methods compare :: Thread a -> Thread a -> Ordering # (<) :: Thread a -> Thread a -> Bool # (<=) :: Thread a -> Thread a -> Bool # (>) :: Thread a -> Thread a -> Bool # (>=) :: Thread a -> Thread a -> Bool # max :: Thread a -> Thread a -> Thread a # min :: Thread a -> Thread a -> Thread a #

scoped :: StructuredConcurrency :> es => (Scope -> Eff es a) -> Eff es a Source #

fork :: StructuredConcurrency :> es => Scope -> Eff es a -> Eff es (Thread a) Source #

forkTry :: Exception e => StructuredConcurrency :> es => Scope -> Eff es a -> Eff es (Thread (Either e a)) Source #

await :: Thread a -> STM a #

Wait for a thread to terminate.

awaitAll :: Scope -> STM () #

Wait until all threads created within a scope terminate.

Extended API

fork_ :: StructuredConcurrency :> es => Scope -> Eff es Void -> Eff es () Source #

forkWith :: StructuredConcurrency :> es => Scope -> ThreadOptions -> Eff es a -> Eff es (Thread a) Source #

forkWith_ :: StructuredConcurrency :> es => Scope -> ThreadOptions -> Eff es Void -> Eff es () Source #

forkTryWith :: Exception e => Scope -> StructuredConcurrency :> es => ThreadOptions -> Eff es a -> Eff es (Thread (Either e a)) Source #

Thread options

data ThreadOptions #

affinity

The affinity of a thread. A thread can be unbound, bound to a specific capability, or bound to a specific OS thread.

Default: Unbound

allocationLimit

The maximum number of bytes a thread may allocate before it is delivered an AllocationLimitExceeded exception. If caught, the thread is allowed to allocate an additional 100kb (tunable with +RTS -xq) to perform any necessary cleanup actions; if exceeded, the thread is delivered another.

Default: Nothing (no limit)

label

The label of a thread, visible in the event log (+RTS -l).

Default: "" (no label)

maskingState

The masking state a thread is created in. To unmask, use unsafeUnmask.

Default: Unmasked

Constructors

ThreadOptions
Fields affinity :: ThreadAffinity allocationLimit :: Maybe ByteCount label :: String maskingState :: MaskingState

Instances

Instances details

Show ThreadOptions
Instance details Defined in Ki.Internal.Thread Methods showsPrec :: Int -> ThreadOptions -> ShowS # show :: ThreadOptions -> String # showList :: [ThreadOptions] -> ShowS #
Eq ThreadOptions
Instance details Defined in Ki.Internal.Thread Methods (==) :: ThreadOptions -> ThreadOptions -> Bool # (/=) :: ThreadOptions -> ThreadOptions -> Bool #

defaultThreadOptions :: ThreadOptions #

Default thread options.

ThreadOptions
  { affinity = Unbound
  , allocationLimit = Nothing
  , label = ""
  , maskingState = Unmasked
  }

data ThreadAffinity #

What, if anything, a thread is bound to.

Constructors

Unbound	Unbound.
Capability Int	Bound to a capability.
OsThread	Bound to an OS thread.

Instances

Instances details

Show ThreadAffinity
Instance details Defined in Ki.Internal.Thread Methods showsPrec :: Int -> ThreadAffinity -> ShowS # show :: ThreadAffinity -> String # showList :: [ThreadAffinity] -> ShowS #
Eq ThreadAffinity
Instance details Defined in Ki.Internal.Thread Methods (==) :: ThreadAffinity -> ThreadAffinity -> Bool # (/=) :: ThreadAffinity -> ThreadAffinity -> Bool #

Byte count

data ByteCount #

A number of bytes.

Instances

Instances details

Show ByteCount
Instance details Defined in Ki.Internal.ByteCount Methods showsPrec :: Int -> ByteCount -> ShowS # show :: ByteCount -> String # showList :: [ByteCount] -> ShowS #
Eq ByteCount
Instance details Defined in Ki.Internal.ByteCount Methods (==) :: ByteCount -> ByteCount -> Bool # (/=) :: ByteCount -> ByteCount -> Bool #
Ord ByteCount
Instance details Defined in Ki.Internal.ByteCount Methods compare :: ByteCount -> ByteCount -> Ordering # (<) :: ByteCount -> ByteCount -> Bool # (<=) :: ByteCount -> ByteCount -> Bool # (>) :: ByteCount -> ByteCount -> Bool # (>=) :: ByteCount -> ByteCount -> Bool # max :: ByteCount -> ByteCount -> ByteCount # min :: ByteCount -> ByteCount -> ByteCount #

kilobytes :: Natural -> ByteCount #

A number of kilobytes.

megabytes :: Natural -> ByteCount #

A number of megabytes.

STM re-export

atomically :: StructuredConcurrency :> es => STM a -> Eff es a Source #

newTVarIO :: StructuredConcurrency :> es => a -> Eff es (TVar a) Source #

newTMVarIO :: StructuredConcurrency :> es => a -> Eff es (TMVar a) Source #

newEmptyTMVarIO :: StructuredConcurrency :> es => Eff es (TMVar a) Source #