oconnore / queues Goto Github PK

(let ((q (queues:make-queue :simple-cqueue)))
  (queues:qpush q 42)
  (queues:qpop q))

Recursive lock attempt #<SB-THREAD:MUTEX "queue-lock" owner: #<SB-THREAD:THREAD "repl-thread" RUNNING {1002E58003}>>.
   [Condition of type SIMPLE-ERROR]

Restarts:
 0: [RETRY] Retry SLIME REPL evaluation request.
 1: [*ABORT] Return to SLIME's top level.
 2: [ABORT] abort thread (#<THREAD "repl-thread" RUNNING {1002E58003}>)

Backtrace:
  0: (SB-THREAD::%TRY-MUTEX #<unavailable argument> #<unavailable argument>)
  1: (SB-THREAD:GRAB-MUTEX #<SB-THREAD:MUTEX "queue-lock" owner: #<SB-THREAD:THREAD "repl-thread" RUNNING {1002E58003}>> :WAITP T :TIMEOUT NIL)
  2: ((FLET #:WITHOUT-INTERRUPTS-BODY-359 :IN SB-THREAD::CALL-WITH-MUTEX))
  3: (SB-THREAD::CALL-WITH-MUTEX #<CLOSURE (FLET SB-THREAD::WITH-MUTEX-THUNK :IN QUEUES:QSIZE) {6A4CBFB}> #<SB-THREAD:MUTEX "queue-lock" owner: #<SB-THREAD:THREAD "repl-thread" RUNNING {1002E58003}>> NIL T..
  4: ((:METHOD QUEUES:QSIZE (QUEUES:SIMPLE-CQUEUE)) #<QUEUES:SIMPLE-CQUEUE 42 [1]>) [fast-method]
  5: ((:METHOD QUEUES:QPOP (QUEUES:SIMPLE-QUEUE)) #<QUEUES:SIMPLE-CQUEUE 42 [1]> NIL) [fast-method]
  6: ((FLET #:WITHOUT-INTERRUPTS-BODY-359 :IN SB-THREAD::CALL-WITH-MUTEX))
  7: (SB-THREAD::CALL-WITH-MUTEX #<CLOSURE (FLET SB-THREAD::WITH-MUTEX-THUNK :IN QUEUES:QPOP) {6A4CE2B}> #<SB-THREAD:MUTEX "queue-lock" owner: #<SB-THREAD:THREAD "repl-thread" RUNNING {1002E58003}>> NIL T ..
  8: ((:METHOD QUEUES:QPOP (QUEUES:SIMPLE-CQUEUE)) #<QUEUES:SIMPLE-CQUEUE 42 [1]>) [fast-method]
  9: (SB-INT:SIMPLE-EVAL-IN-LEXENV (LET ((Q #)) (QUEUES:QPUSH Q 42) (QUEUES:QPOP Q)) #<NULL-LEXENV>)
 10: (EVAL (LET ((Q #)) (QUEUES:QPUSH Q 42) (QUEUES:QPOP Q)))

(in-package queues)
(setf *minimum-size* 2)
(in-package cl-user)
(defparameter q (make-queue :simple-queue))
;notation: (start size vector)
(qpush q 'a) ;(0 1 (a nil))
(qpush q 'b) ;(0 2 (a b))
(qpop q) ;(1 1 (nil b))
(qpush q 'c) ;(1 2 (c b))
(qpush q 'd) ;wrongly (1 3 (c nil nil d)) instead of (3 3 (c d nil b))
;lost b, and also stuck forever as qpop's "unless" prevents popping nil
(print-queue q) ;shows (nil nil d)

--- queues-20120703-git.orig/queue.lisp 2013-02-12 05:05:50.000000000 +0000
+++ quicklisp/dists/quicklisp/software/queues-20120703-git/queue.lisp   2013-03-26 05:49:16.000000000 +0000
@@ -111,7 +111,8 @@
               for x from start below vec-size
               for y from (- new-size (- vec-size start))
               do (setf (aref vector y) (aref vector x)
-               (aref vector x) nil)))))))
+               (aref vector x) nil))
+           (setf (start-of queue) (- new-size (- vec-size start))))))))
     (setf (aref vector (%queue-last queue))
      element)
     (incf (size-of queue))

; file: /Users/robert/quicklisp/dists/quicklisp/software/queues-20170124-git/priority-queue.lisp
; in:
;      DEFMETHOD QUEUES:QUEUE-MERGE-SAFE (QUEUES:PRIORITY-QUEUE QUEUES:PRIORITY-QUEUE)
;     (QUEUES::MAKE-PRIORITY-QUEUE :COMPARE
;      (QUEUES:QUEUE-COMPARISON QUEUES::QUEUE1))
; 
; caught STYLE-WARNING:
;   undefined function: QUEUES::MAKE-PRIORITY-QUEUE
; 
; compilation unit finished
;   Undefined function:
;     QUEUES::MAKE-PRIORITY-QUEUE