Ϫf0 dZddlmZddlmZddlmZddlmZe Z eeGddZ eeGd d Z y ) zE Implementation of an L{IWorker} based on native threads and queues. )Callable) implementer)Quit)IExclusiveWorkerc6eZdZdZdZdegdfddfdZdZy) 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. cL|_t|_fd}||y)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} cRtjtD] }| y)N)iterget_stop)taskqueues @/usr/lib/python3/dist-packages/twisted/_threads/_threadworker.pyworkz#ThreadWorker.__init__..work/s"UYY.  N)_qr_hasQuit)self startThreadrrs ` r__init__zThreadWorker.__init__s$   DrrNreturncn|jj|jj|y)z Perform the given task on the thread owned by this L{ThreadWorker}. @param task: the function to call on a thread. N)rcheckrput)rrs rdozThreadWorker.do5s$   Drcv|jj|jjty)zT Reject all future work and stop the thread started by C{__init__}. N)rsetrrrrs rquitzThreadWorker.quit>s$   Er__name__ __module__ __qualname____doc__rrrr!rrr r s-.xD)drr c6eZdZdZdZdegdfddfdZdZy) LockWorkerzE An L{IWorker} implemented based on a mutual-exclusion lock. c>t|_||_||_y)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)rlocklocals rrzLockWorker.__init__NsV   rrNrc|j}|j}|jjt |dd}|^gx}|_|j ||j |r|jd|r|jd|_y|j |y#|jd|_wxYw)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+rgetattrr1appendacquirepoprelease)rrr.r/r1s rrz LockWorker.do[szz  %D1 ?&( (Gem NN4 LLN %"GKKN$  $ NN4   $ s -B22C cF|jjd|_y)z* Quit this L{LockWorker}. N)r+rr,r s rr!zLockWorker.quitts  rr"r'rrr)r)Hs- !xD)!d!2rr)N) r&typingrzope.interfacer _conveniencer _ithreadsrobjectrr r)r'rrr=s^  &' 000f 000r