+ Dfj Rt^RIHt^RIHtHtHt^RIH t H t ^RIH t ^RI H t ^RIHt^RIHt^RIHtHt!R R ] 4t]3R R lltR #)zR Top level thread pool interface, used to implement L{twisted.python.threadpool}. )Queue)LockThreadlocal)CallableOptional)Protocol)err)IWorker)Team) LockWorker ThreadWorkerc2a]tRt^toV3RlRltRtVtR#)_ThreadFactoryc:<V^8dQhRS[RS[3,RS[/#)target.return)robjectr)format __classdict__s"8/usr/lib/python3/dist-packages/twisted/_threads/_pool.py __annotate___ThreadFactory.__annotate__s$  (3;"7 F cR#N)selfrs&$r__call___ThreadFactory.__call__s rrN)__name__ __module__ __qualname____firstlineno__r__static_attributes____classdictcell__)rs@rrrs  rrcVV^8dQhR\.\3,R\R\/#)r currentLimit threadFactoryr)rintrr )rs"rrrs---2s7#-4B- -rcaaaaRV3RlloRVVV3Rllp\\\4\44V\R7oS#)a Construct a L{Team} that spawns threads as a thread pool, with the given limiting function. @note: Future maintainers: while the public API for the eventual move to twisted.threads should look I{something} like this, and while this function is necessary to implement the API described by L{twisted.python.threadpool}, I am starting to think the idea of a hard upper limit on threadpool size is just bad (turning memory performance issues into correctness issues well before we run into memory pressure), and instead we should build something with reactor integration for slowly releasing idle threads when they're not needed and I{rate} limiting the creation of new threads rather than just hard-capping it. @param currentLimit: a callable that returns the current limit on the number of workers that the returned L{Team} should create; if it already has more workers than that value, no new workers will be created. @type currentLimit: 0-argument callable returning L{int} @param threadFactory: Factory that, when given a C{target} keyword argument, returns a L{threading.Thread} that will run that target. @type threadFactory: callable returning a L{threading.Thread} @return: a new L{Team}. cBV^8dQhR\R\3,RR/#)rr.rN)rr)rs"rrpool..__annotate__;s#44HS&[14d4rc2<S!VR7P4#))r)start)rr)s&r startThreadpool..startThread;sF+1133rc:V^8dQhR\\,/#)rr)rr )rs"rrr->s22(7"32rc<SP4pVPVP,S!48dR#\S\ 44#r) statisticsbusyWorkerCountidleWorkerCountr r)statsr(r0teams rlimitedWorkerCreator"pool..limitedWorkerCreator>s<!  5#8#8 8LN JK11r) coordinator createWorker logException)r r r LocalStorager )r(r)r9r0r8sff @@rpoolr?s>>4422 tv|~6) D KrN)__doc__queuer threadingrrrr>typingrrrtwisted.python.logr _ithreadsr _teamr _threadworkerr r rr?rrrrHsD  99%"3 X FL--r