Qcheck-lin test for MPMC queue

Author: art-w

lockfree.opam

@@ -14,6 +14,7 @@ depends: [
   "qcheck" {with-test & >= "0.18.1"}
   "qcheck-alcotest" {with-test & >= "0.18.1"}
   "yojson" {>= "2.0.2"}
+  "qcheck-lin" {with-test}
 ]
 depopts: []
 build: ["dune" "build" "-p" name "-j" jobs]

test/dune

@@ -21,4 +21,9 @@
 (test
  (name qcheck_mpsc_queue)
  (libraries lockfree qcheck qcheck-alcotest)
- (modules qcheck_mpsc_queue))
+ (modules qcheck_mpsc_queue))
+
+(test
+ (name lin_mpmc_queue)
+ (libraries lockfree qcheck-lin.domain)
+ (modules lin_mpmc_queue))

test/lin_mpmc_queue.ml

@@ -0,0 +1,22 @@
+module Q = Lockfree.Mpmc_queue
+
+module Test = struct
+  type t = int Q.t
+
+  let init () = Q.make ~capacity:1 ()
+
+  let cleanup _ = ()
+
+  open Lin_base
+
+  let api =
+    [ val_ "push" Q.push (t @-> int @-> returning unit)
+    ; val_ "pop"  Q.pop  (t @-> returning (option int))
+    ]
+end
+
+module T = Lin_domain.Make (Test)
+
+let () =
+  QCheck_base_runner.run_tests_main
+    [ T.lin_test ~count:10_000 ~name:"MPMC Queue" ]