o *ήc( @s.ddlZddlZddlmZGdddZdS)N)dequec@s6eZdZddZd ddZddZdd Zd d Zd S) DelayedQueuecCs0||_t|_t|j|_t|_d|_dS)NF) delay_sec threadingLock_lock Condition _not_emptyr_queue_closed)selfdelayrC/tmp/pip-target-vg8gfxp4/lib/python/watchdog/utils/delayed_queue.py__init__s   zDelayedQueue.__init__FcCs8|j|j|t|f|j|jdS)zAdd element to queue.N)racquirer appendtimer notifyrelease)r elementr rrrputs  zDelayedQueue.putcCs(d|_|j|j|jdS)z4Close queue, indicating no more items will be added.TN)r r rrr)r rrrclose&s  zDelayedQueue.closecCs |jt|jdkr|js|jt|jdkr|jr|jr)|jdS|jd\}}}|j|rW||jt}|dkrWt |||jt}|dksE|j &t|jdkry|jdd|ury|j |WdSWdn1swYq)zwRemove and return an element from the queue, or this queue has been closed raise the Closed exception. TrN) r rlenr r waitrrrsleeprpopleft)r head insert_timer time_leftrrrget.s0       zDelayedQueue.getcCsl|j)t|jD]\}\}}}||r#|j|=|WdSq WddS1s/wYdS)zVRemove and return the first items for which predicate is True, ignoring delay.N)r enumerater )r predicateielemtr rrrremoveKs zDelayedQueue.removeN)F)__name__ __module__ __qualname__rrrr r&rrrrrs   r)rr collectionsrrrrrrs