-;;; this should only be called while holding the queue spinlock.
-;;; it releases the spinlock before sleeping
-(defun wait-on-queue (queue &optional lock)
- (let ((pid (current-thread-id)))
- (block-sigcont)
- (when lock (release-mutex lock))
- (sb!sys:without-interrupts
- (pushnew pid (waitqueue-data queue)))
- (setf (waitqueue-lock queue) 0)
- (unblock-sigcont-and-sleep)))
-
-;;; this should only be called while holding the queue spinlock. It doesn't
-;;; release it
-(defun dequeue (queue)
- (let ((pid (current-thread-id)))
- (sb!sys:without-interrupts
- (setf (waitqueue-data queue)
- (delete pid (waitqueue-data queue))))))
-
-;;; this should only be called while holding the queue spinlock.
-(defun signal-queue-head (queue)
- (let ((p (car (waitqueue-data queue))))
- (when p (signal-thread-to-dequeue p))))
-