(require :lparallel)

(defpackage :queue-test
  (:use :lparallel.queue :cl))

(in-package :queue-test)

(defun run ()
  (let ((q (make-queue)))
    (bt:make-thread (lambda ()
                      (loop (push-queue (get-internal-real-time) q) (sleep 1))))
    (loop
      (let ((dt (- (- (pop-queue q) (get-internal-real-time)))))
        (format t "~&~:Dus~%" (* 1r6 (/ dt internal-time-units-per-second)))
        (force-output)))))

(run)