Control.Concurrent.HierarchyInternal

Internal implementations of Control.Concurrent.Hierarchy

Documentation

newtype FinishMarker

FinishMarker is created as empty MVar when a thread is created. It is automatically filled by () when the thread exits.

Constructors

FinishMarker (MVar ())

Instances

Eq FinishMarker

Methods

(==) :: FinishMarker -> FinishMarker -> Bool

(/=) :: FinishMarker -> FinishMarker -> Bool

newtype ThreadMap

Mutable map containing thread ID and finish marker.

Constructors

ThreadMap (TVar (Map ThreadId FinishMarker))

newThreadMap :: MonadBase IO m => m ThreadMap

Create a new empty ThreadMap.

newChild

Arguments

:: MonadBaseControl IO m

=> ThreadMap

ThreadMap where newly created thread will be registered.

-> (ThreadMap -> m ())

Action executed within the new thread.

-> m ThreadId

newChild returns ThreadId of created thread.

Create a new thread and register it to given ThreadMap.

killThreadHierarchy

Arguments

:: MonadBaseControl IO m

=> ThreadMap

ThreadMap containing threads to be killed

-> m ()

Kill all thread registered in given ThreadMap. This version is exposed as API. This is not called from cleanup routine. Thus it doesn't ignore asynchronous exceptions.

killThreadHierarchyInternal

Arguments

:: MonadBaseControl IO m

=> ThreadMap

ThreadMap containing threads to be killed

-> m ()

Kill all thread registered in given ThreadMap. This internal version is only called from cleanup routine so this ignores ThreadKilled asynchronous exception.

cleanup :: MonadBaseControl IO m => FinishMarker -> ThreadMap -> ThreadMap -> m ()

Thread clean up routine automatically installed by newChild. It first killThreadHierarchy all its child threads and unregister itself. This function is not an API function but for internal use only.