a La( @s.ddlZddlZddlmZGdddZdS)N)dequec@s6eZdZddZd ddZddZdd Zd d Zd S) DelayedQueuecCs0||_t|_t|j|_t|_d|_dS)NF) delay_sec threadingZLock_lockZ Condition _not_emptyr_queue_closed)selfdelayr ;lib/python3.9/site-packages/watchdog/utils/delayed_queue.py__init__s  zDelayedQueue.__init__FcCs8|j|j|t|f|j|jdS)zAdd element to queue.N)racquirerappendtimernotifyrelease)r elementr r r r puts  zDelayedQueue.putcCs(d|_|j|j|jdS)z4Close queue, indicating no more items will be added.TN)r rrrr)r r r r close&s  zDelayedQueue.closecCs|jt|jdkr*|js*|jq |jr>|jdS|jd\}}}|j|r||jt}|dkrt |||jt}qn|j Lt|jdkr|jdd|ur|j |WdSWdq1s0YqdS)zwRemove and return an element from the queue, or this queue has been closed raise the Closed exception. rN) rrlenrr waitrrrsleeprpopleft)r headZ insert_timer Z time_leftr r r get.s"       zDelayedQueue.getcCsj|jPt|jD]4\}\}}}||r|j|=|WdSqWdn1s\0YdS)zVRemove and return the first items for which predicate is True, ignoring delay.N)r enumerater)r Z predicateielemtr r r r removeKs 6zDelayedQueue.removeN)F)__name__ __module__ __qualname__rrrrr!r r r r rs  r)rr collectionsrrr r r r s