o b @s^dZddlmZddlmZddlmZeZeeGdddZ eeGdd d Z d S) zE Implementation of an L{IWorker} based on native threads and queues. ) implementer)Quit)IExclusiveWorkerc@(eZdZdZddZddZddZdS) ThreadWorkerz An L{IExclusiveWorker} implemented based on a single thread and a queue. This worker ensures exclusivity (i.e. it is an L{IExclusiveWorker} and not an L{IWorker}) by performing all of the work passed to C{do} on the I{same} thread. cs&|_t|_fdd}||dS)a Create a L{ThreadWorker} with a function to start a thread and a queue to use to communicate with that thread. @param startThread: a callable that takes a callable to run in another thread. @type startThread: callable taking a 0-argument callable and returning nothing. @param queue: A L{Queue} to use to give tasks to the thread created by C{startThread}. @type queue: L{Queue} cstjtD]}|qdS)N)iterget_stop)taskqueue@/usr/lib/python3/dist-packages/twisted/_threads/_threadworker.pywork-sz#ThreadWorker.__init__..workN)_qr_hasQuit)self startThreadr rrr r__init__s  zThreadWorker.__init__cCs|j|j|dS)z Perform the given task on the thread owned by this L{ThreadWorker}. @param task: the function to call on a thread. N)rcheckrput)rr rrrdo3 zThreadWorker.docCs|j|jtdS)zT Reject all future work and stop the thread started by C{__init__}. N)rsetrrr rrrrquit<rzThreadWorker.quitN__name__ __module__ __qualname____doc__rrrrrrrrs  rc@r) LockWorkerzE An L{IWorker} implemented based on a mutual-exclusion lock. cCst|_||_||_dS)z @param lock: A mutual-exclusion lock, with C{acquire} and C{release} methods. @type lock: L{threading.Lock} @param local: Local storage. @type local: L{threading.local} N)r_quit_lock_local)rlocklocalrrrrLs  zLockWorker.__init__cCs|j}|j}|jt|dd}|durJg}|_|||z|r8|d|s&W| d|_dSW| d|_dS| d|_w||dS)z Do the given work on this thread, with the mutex acquired. If this is called re-entrantly, return and wait for the outer invocation to do the work. @param work: the work to do with the lock held. workingNr) r$r%r#rgetattrr(appendacquirepoprelease)rrr&r'r(rrrrYs(       z LockWorker.docCs|jd|_dS)z* Quit this L{LockWorker}. N)r#rr$rrrrrrs  zLockWorker.quitNrrrrrr"Fs  r"N) r!zope.interfacer _conveniencer _ithreadsrobjectr rr"rrrrs   3