tf9dZddlmZddlmZddlmZeZeeGddZ dZ d S) z> Implementation of an in-memory worker that defers execution. ) implementer)IWorker)Quitc(eZdZdZefdZdZdZdS) MemoryWorkerz| An L{IWorker} that queues work for later performance. @ivar _quit: a flag indicating @type _quit: L{Quit} cJt|_||_dS)z+ Create a L{MemoryWorker}. N)r_quit_pending)selfpendings W/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/_threads/_memory.py__init__zMemoryWorker.__init__s VV   cl|j|j|dS)z} Queue some work for to perform later; see L{createMemoryWorker}. @param work: The work to perform. N)r checkr append)r works rdozMemoryWorker.do"s4  T"""""rcv|j|jtdS)z# Quit this worker. N)r setr r NoMoreWork)r s rquitzMemoryWorker.quit+s2  Z(((((rN)__name__ __module__ __qualname____doc__listrrrrrrrsU $""""###)))))rrc2fd}t|fS)a 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. @rtype: 2-L{tuple} of (L{IWorker}, L{callable}) cjsdSjdturdSjddS)NFrT)r rpop)workersrperformz#createMemoryWorker..perform=sL 5 ?1  + +5A   tr)r)r$r#s @rcreateMemoryWorkerr%3s2^^F G rN) rzope.interfacerr _conveniencerobjectrrr%rrrr*s  '&&&&& VXX  W))))))))@r