֛hSrSSKJr SSKJrJr SSKJrJr SSK J r SSK J r SSK Jr "S S \5r\R r\ "\5"S S 55rSS jrg)z> Implementation of an in-memory worker that defers execution. ) annotations)Enumauto)CallableLiteral) implementer)Quit)IExclusiveWorkerc"\rSrSr\"5rSrg)NoMoreN)__name__ __module__ __qualname____firstlineno__rWork__static_attributes__r\C:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/_threads/_memory.pyr r s 6Drr cB\rSrSrSr\4SSjjrS SjrS SjrSr g) MemoryWorkerzl An L{IWorker} that queues work for later performance. @ivar _quit: a flag indicating @type _quit: L{Quit} c:[5UlU"5Ulg)z Create a L{MemoryWorker}. N)r _quit_pending)selfpendings r__init__MemoryWorker.__init__$sV   rcnURR5 URRU5 g)ze Queue some work for to perform later; see L{createMemoryWorker}. @param work: The work to perform. N)rcheckrappend)rworks rdoMemoryWorker.do.s&  T"rcvURR5 URR[5 g)z Quit this worker. N)rsetrr$ NoMoreWork)rs rquitMemoryWorker.quit7s$  Z(r)rrN)rz?Callable[[], list[Callable[[], object] | Literal[NoMore.Work]]]returnNone)r%zCallable[[], object]r-r.)r-r.) rrrr__doc__listr r&r+rrrrrrs/TX"P" "#)rrc0^SU4Sjjn[5mTU4$)z Create an L{IWorker} that does nothing but defer work, to be performed later. @return: a worker that will enqueue work to perform later, and a callable that will perform one element of that work. c>TR(dgTRSnU[LagTRRS5 U"5 g)NFrT)rr*pop)peekworkers rperform#createMemoryWorker..performHs@q! : A r)r-bool)r)r6r5s @rcreateMemoryWorkerr9?s^F G rN)r-z'tuple[MemoryWorker, Callable[[], bool]])r/ __future__renumrrtypingrrzope.interfacer _conveniencer _ithreadsr r rr*rr9rrrr@sZ #$&'T[[   ) ) )Fr