SafeSemaphore-0.10.1: Much safer replacement for QSemN, QSem, and SampleVar

Portabilitynon-portable (concurrency)
Stabilityexperimental
Maintainerhaskell@list.mightyreason.com
Safe HaskellSafe-Inferred

Control.Concurrent.STM.SSem

Description

Very simple quantity semaphore.

Synopsis

Documentation

data SSem Source

Instances

new :: Int -> STM SSemSource

Create a new semaphore with the given argument as the initially available quantity. This allows new semaphores to start with a negative, zero, or positive quantity.

wait :: SSem -> STM ()Source

Try to take a unit of value from the semaphore. This succeeds when the current quantity is positive, and then reduces the quantity by one. Otherwise this will retry. This will never result in a negative quantity. If several threads are retying then which one succeeds next is undefined -- an unlucky thread might starve.

signal :: SSem -> STM ()Source

Signal that single unit of the semaphore is available. This increases the available quantity by one.

tryWait :: SSem -> STM (Maybe Int)Source

Non-retrying version of wait. `tryWait s` is defined as `tryN s 1`

waitN :: SSem -> Int -> STM ()Source

Try to take the given value from the semaphore. This succeeds when the quantity is greater or equal to the given value, and then subtracts the given value from the quantity. Otherwise this will retry. This will never result in a negative quantity. If several threads are retrying then which one succeeds next is undefined -- an unlucky thread might starve.

signalN :: SSem -> Int -> STM ()Source

Signal that many units of the semaphore are available. This changes the available quantity by adding the passed size.

tryWaitN :: SSem -> Int -> STM (Maybe Int)Source

Non-retrying version of waitN. It either takes the quantity from the semaphore like waitN and returns `Just value taken` or finds insufficient quantity to take and returns Nothing

getValue :: SSem -> STM IntSource

Return the current quantity in the semaphore. This is potentially useful in a larger STM transaciton and less useful as `atomically getValueSem :: IO Int` due to race conditions.