package kcas_data

  1. Overview
  2. Docs

Module Kcas_data.QueueSource

First-In First-Out (FIFO) queue.

The interface provides a subset of the OCaml Stdlib.Queue module. transfer and add_seq are not provided at all. Compositional versions of iter, fold, peek, top, and take are not provided.

The queue implementation is designed to avoid contention between a producer and a consumer operating concurrently. The implementation is also designed to avoid starvation. Performance in most concurrent use cases should be superior to what can be achieved with one or two locks.

Common interface

Sourcetype !'a t

The type of queues containing elements of type 'a.

Sourceexception Empty

Raised when take or peek is applied to an empty queue.

Sourceval create : unit -> 'a t

create () returns a new empty queue.

Sourceval copy : 'a t -> 'a t

copy q returns a copy of the queue q.

Compositional interface

Sourcemodule Xt : sig ... end

Explicit transaction log passing on queues.

Non-compositional interface

Sourceval is_empty : 'a t -> bool

is_empty s determines whether the queue q is empty.

Sourceval length : 'a t -> int

length q returns the length of the queue q.

Sourceval clear : 'a t -> unit

clear q removes all elements from the queue q.

Sourceval swap : 'a t -> 'a t -> unit

swap q1 q2 exchanges the contents of the queues q1 and q2.

Sourceval to_seq : 'a t -> 'a Seq.t

to_seq s returns a concurrency and parallelism safe sequence for iterating through the elements of the queue front to back.

The sequence is based on a constant time, O(1), snapshot of the queue and modifications of the queue have no effect on the sequence.

Sourceval add : 'a -> 'a t -> unit

add x q adds the element x at the end of the queue q.

Sourceval push : 'a -> 'a t -> unit

push is a synonym for add.

Sourceval peek_opt : 'a t -> 'a option

peek_opt q returns the first element in queue q, without removing it from the queue, or returns None if the queue is empty.

Sourceval peek_blocking : ?timeoutf:float -> 'a t -> 'a

peek_blocking q returns the first element in queue q, without removing it from the queue, or blocks waiting for the queue to become non-empty.

Sourceval take_blocking : ?timeoutf:float -> 'a t -> 'a

take_blocking q removes and returns the first element in queue q, or blocks waiting for the queue to become non-empty.

Sourceval take_opt : 'a t -> 'a option

take_opt q removes and returns the first element in queue q, or returns None if the queue is empty.

Sourceval take_all : 'a t -> 'a Seq.t

take_all q removes and returns a concurrency and parallelism safe sequence for iterating through all the elements that were in the queue front to back.

Sourceval peek : 'a t -> 'a

peek q returns the first element in queue s, or raises Empty if the queue is empty.

Sourceval top : 'a t -> 'a

top is a synonym for peek.

Sourceval take : 'a t -> 'a

take s removes and returns the first element in queue q, or raises Empty if the queue is empty.

Sourceval iter : ('a -> unit) -> 'a t -> unit

iter f s is equivalent to Seq.iter f (to_seq s).

Sourceval fold : ('b -> 'a -> 'b) -> 'b -> 'a t -> 'b

fold f s is equivalent to Seq.fold_left f a (to_seq s).