Control.Concurrent.AsyncManager

Documentation

data AnyAsync

A existentially quantified wrapper for Async a

Constructors

forall a . AnyAsync (Async a)

data AsyncManager

An Async thread manager. Keeps track of allocated and running Async threads. Useful for ensure threads are cleaned up

Constructors

AsyncManager

Fields

childrenThreads :: MVar (HashMap ThreadId AnyAsync)

childrenManagers :: MVar [AsyncManager]

newAsyncManager :: IO AsyncManager

Create a new empty manager

newChildManager :: AsyncManager -> IO AsyncManager

Create a child manager

insert :: AsyncManager -> Async a -> IO ()

Insert a new thread into the manager TODO: maybe I should check if the computation is still running

clear :: AsyncManager -> IO ()

Cancel all threads and empty the manager

count :: AsyncManager -> IO Int

Thread count. Includes alive and dead threads

compact :: AsyncManager -> IO ()

Remove references to dead threads

cancelWithManager :: AsyncManager -> Async a -> IO ()

Cancel the thread and remove the entry from the manager

asyncWithManager :: AsyncManager -> IO a -> IO (Async a)

Create a new thread and add it to the manager

labelAsyncWithManager :: AsyncManager -> String -> IO a -> IO (Async a)