U -Wj@sdZddlmZddlmZmZddlmZmZddl m Z ddl m Z ddl mZGd d d eZejZe eGd d d Zd dddZdS)z> Implementation of an in-memory worker that defers execution. ) annotations)Enumauto)CallableLiteral) implementer)Quit)IExclusiveWorkerc@seZdZeZdS)NoMoreN)__name__ __module__ __qualname__rWorkrrcc:\users\psant\downloads\hotstarbackend\school\venv38\Lib\site-packages\twisted/_threads/_memory.pyr sr c@sBeZdZdZefdddddZdddd d Zdd d d ZdS) MemoryWorkerz| An L{IWorker} that queues work for later performance. @ivar _quit: a flag indicating @type _quit: L{Quit} z?Callable[[], list[Callable[[], object] | Literal[NoMore.Work]]]None)pendingreturncCst|_||_dS)z+ Create a L{MemoryWorker}. N)r _quit_pending)selfrrrr__init__$szMemoryWorker.__init__zCallable[[], object])workrcCs|j|j|dS)z} Queue some work for to perform later; see L{createMemoryWorker}. @param work: The work to perform. N)rcheckrappend)rrrrrdo.s zMemoryWorker.dorcCs|j|jtdS)z# Quit this worker. N)rsetrr NoMoreWork)rrrrquit7s zMemoryWorker.quitN)r r r__doc__listrrr!rrrrrs    rz'tuple[MemoryWorker, Callable[[], bool]]rcs ddfdd }t|fS)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. boolrcs6js dSjd}|tkr dSjd|dS)NFrT)rr pop)peekZworkerrrperformHs  z#createMemoryWorker..perform)r)r(rr'rcreateMemoryWorker?s  r)N)r" __future__renumrrtypingrrZzope.interfacerZ _conveniencer Z _ithreadsr r rr rr)rrrrs    #