VhdZddlmZddlmZmZddlmZmZddl m Z ddl m Z ddl mZGd d eZej Ze eGd d Zdd Zy)z> Implementation of an in-memory worker that defers execution. ) annotations)Enumauto)CallableLiteral) implementer)Quit)IExclusiveWorkerceZdZeZy)NoMoreN)__name__ __module__ __qualname__rWorkH/home/dcms/DCMS/lib/python3.12/site-packages/twisted/_threads/_memory.pyr r s 6Drr c2eZdZdZef ddZddZddZy) MemoryWorkerz| An L{IWorker} that queues work for later performance. @ivar _quit: a flag indicating @type _quit: L{Quit} c:t|_||_y)z+ Create a L{MemoryWorker}. N)r _quit_pending)selfpendings r__init__zMemoryWorker.__init__$sV   rcn|jj|jj|y)z} Queue some work for to perform later; see L{createMemoryWorker}. @param work: The work to perform. N)rcheckrappend)rworks rdozMemoryWorker.do.s&  T"rcv|jj|jjty)z# Quit this worker. N)rsetrr NoMoreWork)rs rquitzMemoryWorker.quit7s$  Z(rN)rz?Callable[[], list[Callable[[], object] | Literal[NoMore.Work]]]returnNone)r zCallable[[], object]r&r')r&r')rrr__doc__listrr!r%rrrrrs/TX"P" "#)rrc,dfd }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. cjsyjd}|turyjjd|y)NFrT)rr$pop)peekworkers rperformz#createMemoryWorker..performHs@q! : A r)r&bool)r)r/r.s @rcreateMemoryWorkerr1?s^F G rN)r&z'tuple[MemoryWorker, Callable[[], bool]])r( __future__renumrrtypingrrzope.interfacer _conveniencer _ithreadsr r rr$rr1rrrr8sZ #$&'T[[   ) ) )Fr