o ¯bíã@s\dZddlmZddlmZddlmZddlmZGdd„dƒZ eeƒGd d „d ƒƒZ d S) zZ Implementation of a L{Team} of workers; a thread-pool that can allocate work to workers. é)Údeque)Ú implementeré)ÚIWorker)ÚQuitc@seZdZdZdd„ZdS)Ú 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} cCs||_||_||_dS©N)ÚidleWorkerCountÚbusyWorkerCountÚbackloggedWorkCount)Úselfr r r ©r ú8/usr/lib/python3/dist-packages/twisted/_threads/_team.pyÚ__init__#s zStatistics.__init__N)Ú__name__Ú __module__Ú __qualname__Ú__doc__rr r r rrs rc@s\eZdZdZdd„Zdd„Zdd„Zdd d „Zdd d „Zd d„Z dd„Z dd„Z dd„Z dS)ÚTeamax 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. cCs@tƒ|_||_||_||_tƒ|_d|_tƒ|_ d|_ d|_ dS)a  @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Ú _logExceptionÚsetÚ_idleÚ _busyCountrÚ_pendingÚ_shouldQuitCoordinatorÚ _toShrink)r Ú coordinatorÚ createWorkerÚ logExceptionr r rrIs z Team.__init__cCstt|jƒ|jt|jƒƒS)z› Gather information on the current status of this L{Team}. @return: a L{Statistics} describing the current state of this L{Team}. )rÚlenrrr©r r r rÚ statisticsdszTeam.statisticscs$ˆj ¡ˆjj‡‡fdd„ƒ}dS)z— Increase the the number of idle workers by C{n}. @param n: The number of new idle workers to create. @type n: L{int} cs2tˆƒD]}ˆ ¡}|durdSˆ |¡qdSr)ÚrangerÚ_recycleWorker)ÚxÚworker©Únr r rÚcreateOneWorkerus  üz"Team.grow..createOneWorkerN©rÚcheckrÚdo)r r*r+r r)rÚgrowls z Team.growNcs$ˆj ¡ˆj ‡‡fdd„¡dS)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} cs ˆ ˆ¡Sr)Ú _quitIdlersr r)r rÚ†ó zTeam.shrink..Nr,)r r*r r)rÚshrink}s z Team.shrinkcCsp|dur t|jƒ|j}t|ƒD]}|jr|j ¡ ¡q|jd7_q|jr4|jdkr6|j ¡dSdSdS)z| The implmentation of C{shrink}, performed by the coordinator worker. @param n: see L{Team.shrink} Nrr) r"rrr%ÚpopÚquitrrr)r r*r'r r rr0ˆs ÿzTeam._quitIdlerscs$ˆj ¡ˆj ‡‡fdd„¡dS)zu Perform some work in a worker created by C{createWorker}. @param task: the callable to run cs ˆ ˆ¡Sr)Ú_coordinateThisTaskr ©r Útaskr rr1Ÿr2zTeam.do..Nr,r7r r7rr.˜s zTeam.docsXˆjrˆj ¡nˆ ¡‰ˆdurˆj ˆ¡dSˆjd7_ˆj‡‡‡fdd„ƒ}dS)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 Nrcs@zˆƒWn tyˆ ¡Ynwˆjj‡‡fdd„ƒ}dS)Ncsˆjd8_ˆ ˆ¡dS)Nr)rr&r ©r r(r rÚidleAndPendingºsz@Team._coordinateThisTask..doWork..idleAndPending)Ú BaseExceptionrrr.)r:©r r8r(r rÚdoWork³s   ÿz(Team._coordinateThisTask..doWork)rr4rrÚappendrr.)r r8r=r r<rr6¡s  zTeam._coordinateThisTaskcCsl|j |¡|jr| |j ¡¡dS|jr| ¡dS|jdkr4|jd8_|j |¡|  ¡dSdS)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} rrN) rÚaddrr6Úpopleftrr0rÚremover5r9r r rr&¿s     ýzTeam._recycleWorkercs"ˆj ¡ˆjj‡fdd„ƒ}dS)zA Stop doing work and shut down all idle workers. csdˆ_ˆ ¡dS)NT)rr0r r#r rÚstartFinishingÛs z!Team.quit..startFinishingN)rrrr.)r rBr r#rr5Ôs z Team.quitr) rrrrrr$r/r3r0r.r6r&r5r r r rr)s    rN) rÚ collectionsrÚzope.interfacerÚrÚ _conveniencerrrr r r rÚs