Semaphore

Object Hierarchy:

Description:

public class Semaphore : TaskQueue

A high-level non-recursive counting semaphore

This is a semaphore designed for asynchronous GObject programming. It integrates well with the main event loop and provides features such as prioritization, cancellation, and asynchronous interfaces. Requests with higher priorities will always be executed first, and requests of equal priorities will be executed in the order in which they are requested.

Unfortunately, this is relatively slow compared to lower level mutex implementations such as GMutex and pthreads. If you don't require the advanced features, or if you only need short-lived locks, it would probably be much better to use GMutex. However, if you are writing an asynchronous GObject-based application the convenience provided by these methods can go a long way towards helping you write applications don't block the main loop and, therefore, feel faster.

Namespace: Bump

Package: bump-0.1

Content:

Properties:

public int claims { get; }
The current number of claims
public int max_claims { get; construct; }
The maximum number of claims allowed
public TaskQueue pool { get; construct; }
Pool used to process requests

Creation methods:

public Semaphore (int max_claims = 1)

Methods:

public void @lock (int priority = DEFAULT, Cancellable? cancellable = null) throws Error
Synchronously acquire an anonymous claim
public void @unlock ()
Release an anonymous claim
public override void add (owned SourceFunc task, int priority = DEFAULT, Cancellable? cancellable = null) throws Error
public virtual SemaphoreClaim claim (int priority = DEFAULT, Cancellable? cancellable = null) throws Error
Synchronously acquire a claim
public virtual async SemaphoreClaim claim_async (int priority = DEFAULT, Cancellable? cancellable = null) throws Error
Asynchronously acquire a claim
public async void lock_async (int priority = DEFAULT, Cancellable? cancellable = null) throws Error
Asynchronously acquire an anonymous claim
public override bool process (TimeSpan wait = 0)
protected override int spawn (int max = -1)

Inherited Members:

All known members inherited from class Bump.TaskQueue

All known members inherited from class GLib.Object

All known members inherited from interface Bump.Queue

length

process

All known members inherited from interface Bump.Threading