factor/extra/concurrency/conditions/conditions.factor

! Copyright (C) 2008 Slava Pestov.
! See http://factorcode.org/license.txt for BSD license.
USING: dlists dlists.private threads kernel arrays sequences
alarms ;
IN: concurrency.conditions

: notify-1 ( dlist -- )
    dup dlist-empty? [ drop ] [ pop-back resume-now ] if ;

: notify-all ( dlist -- )
    [ resume-now ] dlist-slurp ;

: queue-timeout ( queue timeout -- alarm )
    #! Add an alarm which removes the current thread from the
    #! queue, and resumes it, passing it a value of t.
    >r self over push-front* [
        tuck delete-node
        dlist-node-obj t swap resume-with
    ] 2curry r> later ;

: wait ( queue timeout status -- )
    over [
        >r queue-timeout [ drop ] r> suspend
        [ "Timeout" throw ] [ cancel-alarm ] if
    ] [
        >r drop [ push-front ] curry r> suspend drop
    ] if ;