Simulation.Aivika.Task

Tested with: GHC 7.6.3

The Task value represents a process that was already started in background. We can check the completion of the task, receive notifications about changing its state and even suspend an outer process awaiting the final result of the task. It complements the Process monad as it allows immediately continuing the main computation without suspension.

Task

data Task a

The task represents a process that was already started in background.

data TaskResult a

Represents the result of the task.

Constructors

TaskCompleted a

the task was successfully completed and it returned the specified result

TaskError IOException

the specified exception was raised when performing the task.

TaskCancelled

the task was cancelled

taskId :: Task a -> ProcessId

Return an identifier for the process that was launched in background for this task.

tryGetTaskResult :: Task a -> Event (Maybe (TaskResult a))

Try to get the task result immediately without suspension.

taskResult :: Task a -> Process (TaskResult a)

Return the task result suspending the outer process if required.

taskResultReceived :: Task a -> Signal (TaskResult a)

Return a signal that notifies about receiving the result of the task.

taskProcess :: Task a -> Process a

Return an outer process that behaves like the task itself except for one thing: if the outer process is cancelled then it is not enough to cancel the task.

cancelTask :: Task a -> Event ()

Cancel the task.

taskCancelled :: Task a -> Event Bool

Test whether the task was cancelled.

Running Task

runTask :: Process a -> Event (Task a)

Run the process in background and return the corresponded task immediately.

runTaskUsingId :: ProcessId -> Process a -> Event (Task a)

Run the process with the specified identifier in background and return the corresponded task immediately.

Spawning Tasks

spawnTask :: ContCancellation -> Process a -> Process (Task a)

Run a child process in background and return immediately the corresponded task.

spawnTaskUsingId :: ContCancellation -> ProcessId -> Process a -> Process (Task a)

Run using the specified identifier a child process in background and return immediately the corresponded task.

Enqueueing Task

enqueueTask :: Double -> Process a -> Event (Task a)

Enqueue the process that will be started at the specified time from the event queue. It returns the corresponded task immediately.

enqueueTaskUsingId :: Double -> ProcessId -> Process a -> Event (Task a)

Enqueue the process that will be started at the specified time with the given identifier from the event queue. It returns the corresponded task immediately.