o >h@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__rWorkrrx/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/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)peekworkerrrperformHs  z#createMemoryWorker..performN)rr&)r)r+rr)rcreateMemoryWorker?s  r,N)rr%)r# __future__renumrrtypingrrzope.interfacer _conveniencer _ithreadsr r rr!rr,rrrrs    #