ó ¤Ž©Qc@`s´dZddlmZmZyddlmZWn!ek rSddlmZnXddlZddlZddl Z ddl m Z m Z m Z eƒZddd„ƒYZdS( sº twisted.python.threadpool: a pool of threads to which we dispatch tasks. In most cases you can just use C{reactor.callInThread} and friends instead of creating a thread pool directly. i(tdivisiontabsolute_import(tQueueN(tlogtcontexttfailuret ThreadPoolcB`sàeZdZdZdZeZeZdZdZ e j Z ee jƒZdddd„Zd„Zd„Zd„Zd„Zd „Zd „Zd „Zd „Zejd „ƒZd„Zd„Zddd„Zd„ZRS(s! This class (hopefully) generalizes the functionality of a pool of threads to which work can be dispatched. L{callInThread} and L{stop} should only be called from a single thread, unless you make a subclass where L{stop} and L{_startSomeWorkers} are synchronized. iiicC`sy|dkstdƒ‚||ks0tdƒ‚tdƒ|_||_||_||_g|_g|_g|_dS(s­ Create a new threadpool. @param minthreads: minimum number of threads in the pool @param maxthreads: maximum number of threads in the pool isminimum is negativesminimum is greater than maximumN( tAssertionErrorRtqtmintmaxtnametwaiterstthreadstworking(tselft minthreadst maxthreadsR ((sK/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/python/threadpool.pyt__init__/s     cC`s t|_t|_|jƒdS(s' Start the threadpool. N(tFalsetjoinedtTruetstartedtadjustPoolsize(R((sK/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/python/threadpool.pytstartAs  cC`sj|jd7_d|jp$t|ƒ|jf}|jd|jd|ƒ}|jj|ƒ|jƒdS(NisPoolThread-%s-%sttargetR (tworkersR tidt threadFactoryt_workerR tappendR(RR t newThread((sK/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/python/threadpool.pyt startAWorkerKs "cC`s#|jjtƒ|jd8_dS(Ni(Rtputt WorkerStopR(R((sK/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/python/threadpool.pyt stopAWorkerSscC`s&||_tj||j|jƒdS(N(t__dict__RRR R (Rtstate((sK/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/python/threadpool.pyt __setstate__Xs cC`s$i}|j|d<|j|d<|S(NR R (R R (RR%((sK/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/python/threadpool.pyt __getstate__]s  cC`sL|jjƒt|jƒ}x)|jt|j|ƒkrG|jƒqWdS(N(RtqsizetlenRRR R R (Rt neededSize((sK/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/python/threadpool.pyt_startSomeWorkersdscO`s|jd|||ŽdS(s Call a callable object in a separate thread. @param func: callable object to be called in separate thread @param *args: positional arguments to be passed to C{func} @param **kw: keyword args to be passed to C{func} N(tcallInThreadWithCallbacktNone(Rtfunctargstkw((sK/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/python/threadpool.pyt callInThreadks cO`sb|jr dStjjƒjd}|||||f}|jj|ƒ|jr^|jƒndS(s* Call a callable object in a separate thread and call C{onResult} with the return value, or a L{twisted.python.failure.Failure} if the callable raises an exception. The callable is allowed to block, but the C{onResult} function must not block and should perform as little work as possible. A typical action for C{onResult} for a threadpool used with a Twisted reactor would be to schedule a L{twisted.internet.defer.Deferred} to fire in the main reactor thread using C{.callFromThread}. Note that C{onResult} is called inside the separate thread, not inside the reactor thread. @param onResult: a callable with the signature C{(success, result)}. If the callable returns normally, C{onResult} is called with C{(True, result)} where C{result} is the return value of the callable. If the callable throws an exception, C{onResult} is called with C{(False, failure)}. Optionally, C{onResult} may be C{None}, in which case it is not called at all. @param func: callable object to be called in separate thread @param *args: positional arguments to be passed to C{func} @param **kwargs: keyword arguments to be passed to C{func} Niÿÿÿÿ( RRttheContextTrackertcurrentContexttcontextsRR!RR+(RtonResultR.R/R0tctxto((sK/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/python/threadpool.pyR,xs  cc`s+|j|ƒz dVWd|j|ƒXdS(s+ Manages adding and removing this worker from a list of workers in a particular state. @param stateList: the list managing workers in this state @param workerThread: the thread the worker is running in, used to represent the worker in stateList N(Rtremove(Rt stateListt workerThread((sK/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/python/threadpool.pyt _workerStateŸs  c C`s_|jƒ}|jjƒ}x-|tk rJ|j|j|ƒŒ|\}}}}}~y"tj||||Ž}t} WnAt } |dkr®tj|t j ƒd}q¾t jƒ}nX~~~WdQX|dk rytj||| |ƒWqtj|t j ƒqXn~~~|j|j|ƒ|jjƒ}WdQXqW|jj|ƒdS(s½ Method used as target of the created threads: retrieve a task to run from the threadpool, run it, and proceed to the next task until threadpool is stopped. N(t currentThreadRtgetR"R;RRtcallRRR-RterrRtFailureR R R8( RtctR7R6tfunctionR/tkwargsR5tresulttsuccess((sK/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/python/threadpool.pyR±s2      cC`sit|_tj|jƒ}x,|jrI|jjtƒ|jd8_qWx|D]}|jƒqQWdS(s9 Shutdown the threads in the threadpool. iN( RRtcopyR RRR!R"tjoin(RR tthread((sK/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/python/threadpool.pytstopÙs   cC`sÓ|dkr|j}n|dkr0|j}n|dksHtdƒ‚||ks`tdƒ‚||_||_|jsdSx |j|jkr¡|jƒq‚Wx |j|jkrÄ|jƒq¥W|jƒdS(Nisminimum is negativesminimum is greater than maximum( R-R R RRRR#R R+(RRR((sK/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/python/threadpool.pyRés       cC`sWtjd|jjƒtjd|jƒtjd|jƒtjd|jƒdS(Ns queue: %ss waiters: %ss workers: %ss total: %s(RtmsgRtqueueR RR (R((sK/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/python/threadpool.pyt dumpStatssN( t__name__t __module__t__doc__R R RRRRR-R t threadingtThreadRt staticmethodR<RRR R#R&R'R+R1R,t contextlibtcontextmanagerR;RRIRRL(((sK/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/python/threadpool.pyRs.       ' ( ((ROt __future__RRRt ImportErrorRKRSRPRFttwisted.pythonRRRtobjectR"R(((sK/var/www/html/hlstest/hls-proxy/Twisted-13.2.0/twisted/python/threadpool.pyt s