Source file AList.ml

module Atomic = Opentelemetry_atomic.Atomic

type 'a t = 'a list Atomic.t

let make () = Atomic.make []

let get = Atomic.get

let add self x =
  while
    let old = Atomic.get self in
    let l' = x :: old in
    not (Atomic.compare_and_set self old l')
  do
    ()
  done

let rec pop_all self =
  let l = Atomic.get self in
  if Atomic.compare_and_set self l [] then
    l
  else
    pop_all self