o i@sdZddlmZddlmZmZddlmZmZddl m Z ddl m Z ddl mZGd d d eZejZe eGd d d ZdddZdS)z> Implementation of an in-memory worker that defers execution. ) annotations)Enumauto)CallableLiteral) implementer)Quit)IExclusiveWorkerc@seZdZeZdS)NoMoreN)__name__ __module__ __qualname__rWorkrr^C:\Users\psant\Downloads\PAF backend\school\venv\Lib\site-packages\twisted/_threads/_memory.pyr s r c@s2eZdZdZefdddZdd d Zdd d ZdS) MemoryWorkerz| An L{IWorker} that queues work for later performance. @ivar _quit: a flag indicating @type _quit: L{Quit} pending?Callable[[], list[Callable[[], object] | Literal[NoMore.Work]]]returnNonecCst|_||_dS)z+ Create a L{MemoryWorker}. N)r _quit_pending)selfrrrr__init__$s zMemoryWorker.__init__workCallable[[], object]cCs|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.docCs|j|jtdS)z# Quit this worker. N)rsetrr NoMoreWork)rrrrquit7s zMemoryWorker.quitN)rrrr)rrrr)rr)r r r__doc__listrrr"rrrrrs   rr'tuple[MemoryWorker, Callable[[], bool]]csdfdd }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. rboolcs6jsdSjd}|turdSjd|dS)NFrT)rr!pop)peekZworkerrrperformHs  z#createMemoryWorker..performN)rr&)r)r*rr)rcreateMemoryWorker?s  r+N)rr%)r# __future__renumrrtypingrrZzope.interfacerZ _conveniencer Z _ithreadsr r rr!rr+rrrrs    #