Module Imandra_thread_util.Sync_queue

Synchronized queue

type 'a t
val make : unit -> 'a t
val take : 'a t -> 'a
val take_poll : 'a t -> 'a
val try_take : 'a t -> 'a option

Does not wait

val take_all : 'a t -> 'a list

Does not wait

val push : 'a t -> 'a -> unit
val is_empty : _ t -> bool
val size : _ t -> int