o h7 @s`dZddlmZddlZddlZddlmZddlmZm Z m Z e dZ Gddde e Z dS) u:module: watchdog.utils.delayed_queue :author: thomas.amland@gmail.com (Thomas Amland) :author: contact@tiger-222.fr (Mickaël Schoentgen) ) annotationsN)deque)CallableGenericTypeVarTc@sDeZdZdddZdddd d ZdddZdddZdddZdS) DelayedQueuedelayfloatreturnNonecCs0||_t|_t|j|_t|_d|_dS)NF) delay_sec threadingLock_lock Condition _not_emptyr_queue_closed)selfr rP/var/www/vscode/kcb/lib/python3.10/site-packages/watchdog/utils/delayed_queue.py__init__s   zDelayedQueue.__init__F)r elementrboolcCs8|j|j|t|f|j|jdS)zAdd element to queue.N)racquirerappendtimernotifyrelease)rrr rrrputs  zDelayedQueue.putcCs(d|_|j|j|jdS)z4Close queue, indicating no more items will be added.TN)rrrrr)rrrrcloses  zDelayedQueue.closeT | NonecCs |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) rrlenrrwaitrr rsleeprpopleft)rhead insert_timer time_leftrrrget's0       zDelayedQueue.get predicateCallable[[T], bool]cCsj|j(t|jD]\}^}}||r"|j|=|WdSq WddS1s.wYdS)z_Remove and return the first items for which predicate is True, ignoring delay. N)r enumerater)rr+ielem_rrrremoveDs zDelayedQueue.removeN)r r r r )rrr rr r )r r )r r")r+r,r r")__name__ __module__ __qualname__rr r!r*r1rrrrrs    r) __doc__ __future__rrr collectionsrtypingrrrrrrrrrs