Ϫf9jdZddlmZddlmZddlmZeZeeGddZ dZ y ) z> Implementation of an in-memory worker that defers execution. ) implementer)IWorker)Quitc&eZdZdZefdZdZdZy) 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 :/usr/lib/python3/dist-packages/twisted/_threads/_memory.py__init__zMemoryWorker.__init__sV   cn|jj|jj|y)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"s&  T"rcv|jj|jjty)z# Quit this worker. N)r setr r NoMoreWork)r s rquitzMemoryWorker.quit+s$  Z(rN)__name__ __module__ __qualname____doc__listrrrrrrrs $"#)rrc*fd}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}) cjsyjdturyjjdy)NFrT)r rpop)workersrperformz#createMemoryWorker..perform=s; ??1  +A r)r)r$r#s @rcreateMemoryWorkerr%3s^F G rN) rzope.interfacerr _conveniencerobjectrrr%rrrr*s@  ' X  W)))@r