֛hSrSSKJr SSKJr SSKJrJrJr SSK J r SSK J r SSK Jr SS KJr "S S 5r\ "\ 5"S S 55rg)zZ Implementation of a L{Team} of workers; a thread-pool that can allocate work to workers. ) annotations)deque)CallableOptionalSet) implementer)IWorker)Quit)IExclusiveWorkerc2\rSrSrSrSSjrSrg) Statisticsa Statistics about a L{Team}'s current activity. @ivar idleWorkerCount: The number of idle workers. @type idleWorkerCount: L{int} @ivar busyWorkerCount: The number of busy workers. @type busyWorkerCount: L{int} @ivar backloggedWorkCount: The number of work items passed to L{Team.do} which have not yet been sent to a worker to be performed because not enough workers are available. @type backloggedWorkCount: L{int} c(XlX lX0lgN)idleWorkerCountbusyWorkerCountbackloggedWorkCount)selfrrrs ZC:\Users\psant\Downloads\Noiseback\school\venv\Lib\site-packages\twisted/_threads/_team.py__init__Statistics.__init__%s /.#6 )rrrN)rintrrrrreturnNone)__name__ __module__ __qualname____firstlineno____doc__r__static_attributes__rrrrs, 7"7587OR7 7rrc\rSrSrSrSSjrSSjrSSjrSSSjjrSSSjjr SS jr SS jr SS jr SS jr S rg)Team-a, A composite L{IWorker} implementation. @ivar _quit: A L{Quit} flag indicating whether this L{Team} has been quit yet. This may be set by an arbitrary thread since L{Team.quit} may be called from anywhere. @ivar _coordinator: the L{IExclusiveWorker} coordinating access to this L{Team}'s internal resources. @ivar _createWorker: a callable that will create new workers. @ivar _logException: a 0-argument callable called in an exception context when there is an unhandled error from a task passed to L{Team.do} @ivar _idle: a L{set} of idle workers. @ivar _busyCount: the number of workers currently busy. @ivar _pending: a C{deque} of tasks - that is, 0-argument callables passed to L{Team.do} - that are outstanding. @ivar _shouldQuitCoordinator: A flag indicating that the coordinator should be quit at the next available opportunity. Unlike L{Team._quit}, this flag is only set by the coordinator. @ivar _toShrink: the number of workers to shrink this L{Team} by at the next available opportunity; set in the coordinator. c[5UlXlX lX0l[ 5UlSUl[5Ul SUl SUl g)aH @param coordinator: an L{IExclusiveWorker} which will coordinate access to resources on this L{Team}; that is to say, an L{IExclusiveWorker} whose C{do} method ensures that its given work will be executed in a mutually exclusive context, not in parallel with other work enqueued by C{do} (although possibly in parallel with the caller). @param createWorker: A 0-argument callable that will create an L{IWorker} to perform work. @param logException: A 0-argument callable called in an exception context when the work passed to C{do} raises an exception. rFN) r _quit _coordinator _createWorker _logExceptionset_idle _busyCountr_pending_shouldQuitCoordinator _toShrink)r coordinator createWorker logExceptions rr Team.__init__MsI(V '))$'5 8= &+#rc|[[UR5UR[UR55$)z Gather information on the current status of this L{Team}. @return: a L{Statistics} describing the current state of this L{Team}. )rlenr-r.r/rs r statisticsTeam.statisticsms( #djj/4??C [T5H)nTR5nUc gTRU5 M+ gr)ranger*_recycleWorker)xworkernrs rcreateOneWorker"Team.grow..createOneWorker~s51X++->##F+ rNrrr(checkr)do)rrArBs`` rgrow Team.growus3      ,  ,rNc|^^TRR5 TRRUU4Sj5 g)z Decrease the number of idle workers by C{n}. @param n: The number of idle workers to shut down, or L{None} (or unspecified) to shut down all workers. @type n: L{int} or L{None} c&>TRT5$r) _quitIdlers)rArsrTeam.shrink..sT%5%5a%8rNrE)rrAs``rshrink Team.shrinks*  89rcUc"[UR5UR-n[U5HSnUR(a*URR 5R 5 M>U=R S- slMU UR(a,URS:XaURR 5 ggg)zd The implmentation of C{shrink}, performed by the coordinator worker. @param n: see L{Team.shrink} Nr r) r7r-r.r=popquitr1r0r))rrAr?s rrLTeam._quitIdlerss 9DJJ$//1AqAzz  %%'!#   & &4??a+?    " " $,@ &rc|^^TRR5 TRRUU4Sj5 g)z] Perform some work in a worker created by C{createWorker}. @param task: the callable to run c&>TRT5$r)_coordinateThisTaskrtasksrrMTeam.do..sT%=%=d%CrNrErXs``rrGTeam.dos*  CDrc^^^TR(aTRR5OTR5nUcTRR T5 gUmT=R S- slUR SUUU4Sjj5ng)z Select a worker to dispatch to, either an idle one or a new one, and perform it. This method should run on the coordinator worker. @param task: the task to dispatch @type task: 0-argument callable Nr c>T"5 TRRSUU4Sjj5ng![a TR5 N?f=f)NcR>T=RS-slTRT5 g)Nr )r.r>)not_none_workerrsridleAndPending@Team._coordinateThisTask..doWork..idleAndPendings1$##O4rrD) BaseExceptionr+r)rG)r`r_rrYs rdoWork(Team._coordinateThisTask..doWorksJ %   ! ! 5" 5 ! %""$ %s-A  A rD)r-rRr*r/appendr.rG)rrYr@rcr_s`` @rrWTeam._coordinateThisTasksp&*ZZ!T5G5G5I > MM  &   1  5 5  5rcURRU5 UR(a*URURR 55 gUR (aUR 5 gURS:aAU=RS-slURRU5 UR5 gg)z Called only from coordinator. Recycle the given worker into the idle pool. @param worker: a worker created by C{createWorker} and now idle. @type worker: L{IWorker} rr N) r-addr/rWpopleftr0rLr1removerS)rr@s rr>Team._recycleWorkers v ==  $ $T]]%:%:%< =  ( (     ^^a  NNa N JJ  f % KKM rc|^TRR5 TRRSU4Sjj5ng)z1 Stop doing work and shut down all idle workers. c4>STlTR5 g)NT)r0rLr8srstartFinishing!Team.quit..startFinishings*.D '    rNrD)r(r,r)rG)rrns` rrS Team.quits3         r) r.r)r*r-r+r/r(r0r1)r2r r3zCallable[[], Optional[IWorker]]r4zCallable[[], None])rr)rArrrr)rAz Optional[int]rr)rYzCallable[[], object]rr)rYzCallable[..., object]rr)r@r rrrD)rrrr r!rr9rHrOrLrGrWr>rSr"r#rrr%r%-sS<%6) @P," :% E5>* rr%N)r! __future__r collectionsrtypingrrrzope.interfacerr _conveniencer _ithreadsr rr%r#rrrxsO #**&'770 Wzzzr