o ¯b9ã@sPdZddlmZddlmZddlmZeƒZeeƒGdd„dƒƒZ dd „Z d S) z> Implementation of an in-memory worker that defers execution. é)Ú implementeré)ÚIWorker)ÚQuitc@s,eZdZdZefdd„Zdd„Zdd„ZdS) Ú MemoryWorkerz| An L{IWorker} that queues work for later performance. @ivar _quit: a flag indicating @type _quit: L{Quit} cCstƒ|_|ƒ|_dS)z+ Create a L{MemoryWorker}. N)rÚ_quitÚ_pending)ÚselfÚpending©r ú:/usr/lib/python3/dist-packages/twisted/_threads/_memory.pyÚ__init__s zMemoryWorker.__init__cCs|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 Úworkr r r Údo"s zMemoryWorker.docCs|j ¡|j t¡dS)z# Quit this worker. N)rÚsetrrÚ NoMoreWork)r r r r Úquit+s zMemoryWorker.quitN)Ú__name__Ú __module__Ú __qualname__Ú__doc__Úlistr rrr r r r rs   rcs‡fdd„}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}) cs.ˆjsdSˆjdturdSˆj d¡ƒdS)NFrT)rrÚpopr ©Úworkerr r Úperform=s z#createMemoryWorker..perform)r)rr rr ÚcreateMemoryWorker3s rN) rÚzope.interfacerÚrÚ _conveniencerÚobjectrrrr r r r Ús