Changeset 40 for branches/home/psmith/restructure/src/compat

Timestamp:

01/17/07 05:06:13 (18 years ago)

Author:

psmith

Message:

yarpc work, saving...

File:

• branches/home/psmith/restructure/src/compat/concurrent-queue.lisp (modified) (2 diffs)

branches/home/psmith/restructure/src/compat/concurrent-queue.lisp ¶

@@ -52 +52 @@
        nil))
 
-
-(defmethod take ((queue concurrent-queue))
+;Do an (optionally blocking) remove of the element at the head of this queue
+(defmethod take ((queue concurrent-queue) &key (blocking-call t))
   (sb-thread:with-mutex ((buffer-lock queue))
     ;if its there, pop it
     (let ((ret (pop-elt (buffer queue) "1sttry")))
-      (if ret
+      (if (or ret (not blocking-call))
           ret
           (progn
@@ -63 +63 @@
             (pop-elt (buffer queue) "2ndtry"))))))
 
-
+;Append the element to the tail of this queue
 (defmethod add ((queue concurrent-queue) elt)
   (sb-thread:with-mutex ((buffer-lock queue))