ganeti-3.1: Cluster-based virtualization management software
Safe HaskellSafe-Inferred
LanguageHaskell2010

Ganeti.Utils.AsyncWorker

Description

Provides a general functionality for workers that run on the background and perform some task when triggered.

Each task can process multiple triggers, if they're coming faster than the tasks are being processed.

Properties:

  • If a worked is triggered, it will perform its action eventually. (i.e. it won't miss a trigger).
  • If the worker is busy, the new action will start immediately when it finishes the current one.
  • If the worker is idle, it'll start the action immediately.
  • If the caller uses triggerAndWait, the call will return just after the earliest action following the trigger is finished.
  • If the caller uses triggerWithResult, it will recive an Async value that can be used to wait for the result (which will be available once the earliest action following the trigger finishes).
  • If the worker finishes an action and there are no pending triggers since the start of the last action, it becomes idle and waits for a new trigger.
Synopsis

Documentation

data AsyncWorker i a #

Represent an asynchronous worker whose single action execution returns a value of type a.

mkAsyncWorker :: (Monoid i, MonadBaseControl IO m) => (i -> m a) -> m (AsyncWorker i a) #

Given an action, construct an AsyncWorker.

mkAsyncWorker_ :: MonadBaseControl IO m => m a -> m (AsyncWorker () a) #

Given an action, construct an AsyncWorker with no input.

trigger :: (MonadBase IO m, Monoid i) => i -> AsyncWorker i a -> m () #

Trigger a worker, letting it run its action asynchronously, but do not wait for the result.

trigger_ :: MonadBase IO m => AsyncWorker () a -> m () #

Trigger a worker with no input, letting it run its action asynchronously, but do not wait for the result.

triggerWithResult :: (MonadBase IO m, Monoid i) => i -> AsyncWorker i a -> m (Async a) #

Trigger a worker and wait until the action following this trigger finishes. The returned Async value can be used to wait for the result of the action.

triggerWithResult_ :: MonadBase IO m => AsyncWorker () a -> m (Async a) #

Trigger a worker and wait until the action following this trigger finishes.

See triggerWithResult.

triggerWithResultMany :: (Traversable t, MonadBase IO m, Monoid i) => i -> t (AsyncWorker i a) -> m (t (Async a)) #

Trigger a list of workers and wait until all the actions following these triggers finish. The returned collection of Async values can be used to wait for the results of the actions.

triggerWithResultMany_ :: (Traversable t, MonadBase IO m) => t (AsyncWorker () a) -> m (t (Async a)) #

Trigger a list of workers with no inputs and wait until all the actions following these triggers finish.

See triggerWithResultMany.

triggerAndWait :: (MonadBase IO m, Monoid i) => i -> AsyncWorker i a -> m a #

Trigger a worker and wait until the action following this trigger finishes. Return the result of the action.

triggerAndWait_ :: MonadBase IO m => AsyncWorker () a -> m a #

Trigger a worker with no input and wait until the action following this trigger finishes. Return the result of the action.

triggerAndWaitMany :: (Traversable t, MonadBase IO m, Monoid i) => i -> t (AsyncWorker i a) -> m (t a) #

Trigger a list of workers and wait until all the actions following these triggers finish. Returns the results of the actions.

Note that there is a significant difference between triggerAndWaitMany and mapM triggerAndWait. The latter runs all the actions of the workers sequentially, while the former runs them in parallel.

triggerAndWaitMany_ :: (Traversable t, MonadBase IO m) => t (AsyncWorker () a) -> m (t a) #

data Async a #

An asynchronous result that will eventually yield a value.

wait :: MonadBase IO m => Async a -> m a #

Waits for an asynchronous result to finish and yield a value.

waitMany :: (MonadBase IO m, Traversable t) => t (Async a) -> m (t a) #

Waits for all asynchronous results in a collection to finish and yield a value.