֛hZb%SrSSKJr SSKJrJr SSKJrJrJ r J r J r J r \(aSSK r SSKJr SSKJr SS KJr "S S \5r\R*r\ "S 5r\ "S 5r"SS\ \5rS\S'\r\"\5"SS55r"SS\ 5r\"\5"SS55rg)zE Implementation of an L{IWorker} based on native threads and queues. ) annotations)Enumauto) TYPE_CHECKINGCallableIteratorLiteralProtocolTypeVarN) implementer)Quit)IExclusiveWorkerc"\rSrSr\"5rSrg)StopN)__name__ __module__ __qualname____firstlineno__rThread__static_attributes__rbC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/_threads/_threadworker.pyrrs VFrrTUc(\rSrSrSSjrSSjrSrg) SimpleQueue cgNr)selfitems rputSimpleQueue.put! rcgr"rr#s rgetSimpleQueue.get$r'rrN)r$rreturnNone)r,r)rrrrr%r*rrrrrr   rrz/Callable[[Callable[[], T | U], U], Iterator[T]] smartiterc>\rSrSrSrSSjrS SjrS SjrSrg) ThreadWorker-z 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. cR^TUl[5UlSU4SjjnU"U5 g)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. @param queue: A L{Queue} to use to give tasks to the thread created by C{startThread}. cV>[TR[5H nU"5 M gr")r/r* StopThread)taskqueues rwork#ThreadWorker.__init__..workIs!%))Z89rNr,r-)_qr_hasQuit)r# startThreadr7r8s ` r__init__ThreadWorker.__init__7s$   DrcnURR5 URRU5 g)zu Perform the given task on the thread owned by this L{ThreadWorker}. @param task: the function to call on a thread. N)r<checkr;r%)r#r6s rdoThreadWorker.doOs$   DrcvURR5 URR[5 g)zD Reject all future work and stop the thread started by C{__init__}. N)r<setr;r%r5r)s rquitThreadWorker.quitXs$   Jr)r<r;N)r=z(Callable[[Callable[[], object]], object]r7z8SimpleQueue[Callable[[], object] | Literal[Stop.Thread]])r6Callable[[], None]r,r-r: rrrr__doc__r>rBrFrrrrr1r1-s)=H0 rr1c(\rSrSrSSjrSSjrSrg) SimpleLockbcgr"rr)s racquireSimpleLock.acquirecr'rcgr"rr)s rreleaseSimpleLock.releasefr'rrN)r,boolr:)rrrrrOrRrrrrrLrLbr.rrLc6\rSrSrSrSSjrS SjrS SjrSrg) LockWorkerjz= An L{IWorker} implemented based on a mutual-exclusion lock. c:[5UlXlX lg)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)r#locklocals rr>LockWorker.__init__psV (,  rcURnURnURR5 [ USS5nUcrUcS5e/=oClUR U5 UR5 U(aURS5"5 U(aMUR5 SUlgUR U5 g!UR5 SUlf=f)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. workingNzLockWorker used after quit()r) rZr[rYrAgetattrr`appendrOpoprR)r#r8r\r]r`s rrB LockWorker.do}szz  %D1 ?# C%C C#&( (Gm NN4 LLN %KKN$g  $ NN4   $ s 7$CC cFURR5 SUlg)z Quit this L{LockWorker}. N)rYrErZr)s rrFLockWorker.quits  r)r[rZrYN)r\rLr]zthreading.local)r8rHr,r-r:rIrrrrVrVjs !4rrV) rJ __future__renumrrtypingrrrr r r threadingzope.interfacer _conveniencer _ithreadsrrrr5rrr__annotations__iterr/r1rLrVrrrrps #PP&'4[[  CL CL (1+  ;:   1 1 1 h   111r