ÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂÂ 3 ct„jØÃã@s|ddlZddlZddlmZmZddlm Z ddlmZddl mZmZyddlmZWn ek rxddlmZYnXddd d ddd ddddddddddddddgZejZejZejZejZejZy ej Z!Wne"k rèdZ!YnXej#Z#[da$da%dd„Z&dd„Z'eZ(dd„Z Gdd „d ƒZ)e)Z*Gd!d „d ƒZ+Gd"d„dƒZ,Gd#d„de,ƒZ-Gd$d„dƒZ.Gd%d„dƒZ/Gd&d„de0ƒZ1eƒj2Z3e3ƒd?d(d)„Z4e ƒa5iZ6iZ7eƒZ8Gd*d„dƒZ9Gd+d„de9ƒZ:Gd,d-„d-e9ƒZ;Gd.d/„d/e9ƒZd1d„Z?e?Z@d2d3„ZAd4d„ZBdd5lmCZCe;ƒaDd6d7„ZEd8d9„ZFd:d„ZGydd;lmHZIWn"ek rndd„ZKdS)@éN)Ú monotonicÚsleep)Ú format_exc)ÚWeakSet)ÚisliceÚcount)ÚdequeÚ get_identÚactive_countÚ ConditionÚcurrent_threadÚ enumerateÚmain_threadÚTIMEOUT_MAXÚEventÚLockÚRLockÚ SemaphoreÚBoundedSemaphoreÚThreadÚBarrierÚBrokenBarrierErrorÚTimerÚThreadErrorÚ setprofileÚsettraceÚlocalÚ stack_sizecCs|adS)N)Ú _profile_hook)Úfunc©r ú!/usr/lib64/python3.6/threading.pyr2scCs|adS)N)Ú_trace_hook)rr r r!r<scOstdkrt||ŽSt||ŽS)N)Ú_CRLockÚ_PyRLock)ÚargsÚkwargsr r r!rJs c@sReZdZdd„Zdd„Zddd„ZeZd d „Zdd„Zd d„Z dd„Z dd„ZdS)Ú_RLockcCstƒ|_d|_d|_dS)Nr)Ú_allocate_lockÚ_blockÚ_ownerÚ_count)Úselfr r r!Ú__init__asz_RLock.__init__cCs^|j}yt|j}Wntk r(YnXd|jjƒr:dnd|jj|jj||j t t|ƒƒfS)Nz)<%s %s.%s object owner=%r count=%d at %s>ÚlockedZunlocked)r*Ú_activeÚnameÚKeyErrorr)r.Ú __class__Ú __module__Ú__qualname__r+ÚhexÚid)r,Úownerr r r!Ú__repr__fsz_RLock.__repr__TécCsDtƒ}|j|kr"|jd7_dS|jj||ƒ}|r@||_d|_|S)Nr9)r r*r+r)Úacquire)r,ÚblockingÚtimeoutÚmeÚrcr r r!r:us z_RLock.acquirecCs<|jtƒkrtdƒ‚|jd|_}|s8d|_|jjƒdS)Nzcannot release un-acquired lockr9)r*r ÚRuntimeErrorr+r)Úrelease)r,rr r r!r@›sz_RLock.releasecCs|jƒdS)N)r@)r,ÚtÚvÚtbr r r!Ú__exit__²sz_RLock.__exit__cCs|jjƒ|\|_|_dS)N)r)r:r+r*)r,Ústater r r!Ú_acquire_restore·s z_RLock._acquire_restorecCs<|jdkrtdƒ‚|j}d|_|j}d|_|jjƒ||fS)Nrzcannot release un-acquired lock)r+r?r*r)r@)r,rr7r r r!Ú _release_save»s z_RLock._release_savecCs|jtƒkS)N)r*r )r,r r r!Ú _is_ownedÅsz_RLock._is_ownedNéÿÿÿÿ)TrI)Ú__name__r3r4r-r8r:Ú __enter__r@rDrFrGrHr r r r!r'Ws $ r'c@speZdZddd„Zdd„Zdd„Zdd „Zd d„Zdd „Zdd„Z ddd„Z ddd„Zddd„Zdd„Z e ZdS)rNcCs–|dkrtƒ}||_|j|_|j|_y|j|_Wntk rDYnXy|j|_Wntk rfYnXy|j|_Wntk rˆYnXtƒ|_ dS)N) rÚ_lockr:r@rGÚAttributeErrorrFrHÚ_dequeÚ_waiters)r,Úlockr r r!r-×s$zCondition.__init__cCs |jjƒS)N)rLrK)r,r r r!rKïszCondition.__enter__cGs|jj|ŽS)N)rLrD)r,r%r r r!rDòszCondition.__exit__cCsd|jt|jƒfS)Nz)rLÚlenrO)r,r r r!r8õszCondition.__repr__cCs|jjƒdS)N)rLr@)r,r r r!rGøszCondition._release_savecCs|jjƒdS)N)rLr:)r,Úxr r r!rFûszCondition._acquire_restorecCs"|jjdƒr|jjƒdSdSdS)NrFT)rLr:r@)r,r r r!rHþs zCondition._is_ownedcCsö|jƒstdƒ‚tƒ}|jƒ|jj|ƒ|jƒ}d}z„|dkrN|jƒd}nj|dkr®tƒ|}d}xR|jdƒ}|rvPt|tƒ|ƒ}|dkrPt|d|dƒ}t |ƒqfWn |jdƒ}|S|j |ƒ|sðy|jj|ƒWntk rîYnXXdS)Nzcannot wait on un-acquired lockFTrgü©ñÒMb@?égš™™™™™©?) rHr?r(r:rOÚappendrGÚ_timeÚminÚ_sleeprFÚremoveÚ ValueError)r,r<ÚwaiterZsaved_stateZgotitÚendtimeZdelayZ remainingr r r!Úwaits> zCondition.waitcCs\d}|}|ƒ}xH|sV|dk rD|dkr0tƒ|}n|tƒ}|dkrDP|j|ƒ|ƒ}qW|S)Nr)rUr\)r,Z predicater<r[ZwaittimeÚresultr r r!Úwait_forIs zCondition.wait_forr9cCsj|jƒstdƒ‚|j}tt||ƒƒ}|s,dSx8|D]0}|jƒy|j|ƒWq2tk r`Yq2Xq2WdS)Nz!cannot notify on un-acquired lock)rHr?rOrNÚ_islicer@rXrY)r,ÚnZall_waitersZwaiters_to_notifyrZr r r!Únotify`s zCondition.notifycCs|jt|jƒƒdS)N)rarQrO)r,r r r!Ú notify_allwszCondition.notify_all)N)N)N)r9)rJr3r4r-rKrDr8rGrFrHr\r^rarbZ notifyAllr r r r!rËs B c@s4eZdZddd„Zd dd„ZeZdd „Zd d„ZdS)rr9cCs&|dkrtdƒ‚ttƒƒ|_||_dS)Nrz$semaphore initial value must be >= 0)rYrrÚ_condÚ_value)r,Úvaluer r r!r-szSemaphore.__init__TNc Cs˜|r|dk rtdƒ‚d}d}|jjxb|jdkrv|s8P|dk rh|dkrTtƒ|}n|tƒ}|dkrhP|jj|ƒq(W|jd8_d}WdQRX|S)Nz.can't specify timeout for non-blocking acquireFrr9T)rYrcrdrUr\)r,r;r<r>r[r r r!r:•s$ zSemaphore.acquirec Cs.|j|jd7_|jjƒWdQRXdS)Nr9)rcrdra)r,r r r!r@ÄszSemaphore.releasecCs|jƒdS)N)r@)r,rArBrCr r r!rDÏszSemaphore.__exit__)r9)TN)rJr3r4r-r:rKr@rDr r r r!rƒs -c@seZdZddd„Zdd„ZdS)rr9cCstj||ƒ||_dS)N)rr-Ú_initial_value)r,rer r r!r-äszBoundedSemaphore.__init__c CsB|j2|j|jkrtdƒ‚|jd7_|jjƒWdQRXdS)Nz!Semaphore released too many timesr9)rcrdrfrYra)r,r r r!r@ès zBoundedSemaphore.releaseN)r9)rJr3r4r-r@r r r r!rÓs c@sBeZdZdd„Zdd„Zdd„ZeZdd„Zd d „Zddd „Z dS)rcCsttƒƒ|_d|_dS)NF)rrrcÚ_flag)r,r r r!r-szEvent.__init__cCs|jjtƒƒdS)N)rcr-r)r,r r r!Ú_reset_internal_locksszEvent._reset_internal_lockscCs|jS)N)rg)r,r r r!Úis_setszEvent.is_setc Cs&|jd|_|jjƒWdQRXdS)NT)rcrgrb)r,r r r!Úsetsz Event.setc Cs|jd|_WdQRXdS)NF)rcrg)r,r r r!ÚclearszEvent.clearNc Cs,|j|j}|s|jj|ƒ}|SQRXdS)N)rcrgr\)r,r<Zsignaledr r r!r\'s z Event.wait)N) rJr3r4r-rhriZisSetrjrkr\r r r r!rùs c@s|eZdZddd„Zddd„Zdd„Zdd „Zd d„Zdd „Zdd„Z dd„Z dd„Zedd„ƒZ edd„ƒZedd„ƒZdS)rNcCs.ttƒƒ|_||_||_||_d|_d|_dS)Nr)rrrcÚ_actionÚ_timeoutÚ_partiesÚ_stater+)r,ÚpartiesÚactionr<r r r!r-Qs zBarrier.__init__cCs€|dkr|j}|jb|jƒ|j}|jd7_z&|d|jkrL|jƒn |j|ƒ|S|jd8_|jƒXWdQRXdS)Nr9)rmrcÚ_enterr+rnÚ_releaseÚ_waitÚ_exit)r,r<Úindexr r r!r\as zBarrier.waitcCs,x|jdkr|jjƒqW|jdkr(t‚dS)Nr9rrI)rIr9)rorcr\r)r,r r r!rrs zBarrier._enterc Cs>y"|jr|jƒd|_|jjƒWn|jƒ‚YnXdS)Nr9)rlrorcrbÚ_break)r,r r r!rsŠszBarrier._releasecs4ˆjj‡fdd„|ƒs"ˆjƒt‚ˆjdkr0t‚dS)Ncs ˆjdkS)Nr)ror )r,r r!Ú™szBarrier._wait..r)rcr^rwrro)r,r<r )r,r!rt˜s z Barrier._waitcCs(|jdkr$|jdkr$d|_|jjƒdS)Nrr9rI)rIr9)r+rorcrb)r,r r r!ru£s z Barrier._exitc CsT|jD|jdkr6|jdkr$d|_q<|jdkr||_n tƒj|_d|_ d|_ tƒ|_d|_ d|_tj|_tj|ƒdS)NFT)Ú_targetÚstrr‚Ú_nameÚ_argsÚ_kwargsÚ _daemonicrrƒÚ_identÚ_tstate_lockrÚ_startedÚ_is_stoppedÚ_initializedÚ_sysÚstderrÚ_stderrÚ _danglingÚadd)r,ÚgroupÚtargetr0r%r&rƒr r r!r- s zThread.__init__cCs(|jjƒ|r|jƒnd|_d|_dS)NT)rŒrhÚ_set_tstate_lockrr‹)r,Úis_aliver r r!rh7s zThread._reset_internal_lockscCs^d}|jjƒrd}|jƒ|jr$d}|jr2|d7}|jdk rJ|d|j7}d|jj|j|fS)NÚinitialZstartedZstoppedz daemonz %sz<%s(%s, %s)>) rŒrir—rr‰rŠr2rJr†)r,Zstatusr r r!r8Cs zThread.__repr__cCs„|jstdƒ‚|jjƒr tdƒ‚t|t|<WdQRXyt|jfƒWn,tk rttt|=WdQRX‚YnX|jj ƒdS)Nzthread.__init__() not calledz threads can only be started once) rŽr?rŒriÚ_active_limbo_lockÚ_limboÚ_start_new_threadÚ _bootstrapÚ Exceptionr\)r,r r r!ÚstartQs zThread.startc Cs.z|jr|j|j|jŽWd|`|`|`XdS)N)r„r‡rˆ)r,r r r!Úrunjs z Thread.runc Cs2y|jƒWn |jr&tdkr&dS‚YnXdS)N)Ú_bootstrap_innerr‰r)r,r r r!rœ{s zThread._bootstrapcCstƒ|_dS)N)r rŠ)r,r r r!Ú _set_identszThread._set_identcCstƒ|_|jjƒdS)N)Ú _set_sentinelr‹r:)r,r r r!r–’szThread._set_tstate_lockc2CsˆzT|jƒ|jƒ|jjƒt|t|j<t|=WdQRXtrLt j tƒtrZt jtƒzöy|j ƒWnätk r|YnÒt r¬t jdk r¬td|jtƒft jdnœ|jdk rH|jƒ\}}}zxtd|jd|jdtd|jdx6|r$td|jjj|j|jjjf|jd|j}qðWtd||f|jdWd~~~XYnXWdXWdt yttƒ=WnYnXWdQRXXdS)NzException in thread %s: %s)ÚfilezException in thread z2 (most likely raised during interpreter shutdown):z"Traceback (most recent call last):z File "%s", line %s, in %sz%s: %s)r¡r–rŒrjr™r/rŠršr"rrrrrŸÚ SystemExitrÚprintr0Ú_format_excr‘Ú _exc_infoÚtb_frameÚf_codeÚco_filenameÚ tb_linenoÚco_nameÚtb_nextr )r,Úexc_typeÚ exc_valueZexc_tbr r r!r šsT zThread._bootstrap_innercCs|j}|dk rd|_d|_dS)NT)r‹r)r,rPr r r!Ú_stopÛszThread._stopcCsBytttƒ=WdQRXWn tk r<dtjkr8‚YnXdS)NZdummy_threading)r™r/r r1rÚmodules)r,r r r!Ú_deleteòs zThread._deletecCsZ|jstdƒ‚|jjƒs tdƒ‚|tƒkr2tdƒ‚|dkrD|jƒn|jt|dƒddS)NzThread.__init__() not calledz'cannot join thread before it is startedzcannot join current threadr)r<)rŽr?rŒrirÚ_wait_for_tstate_lockÚmax)r,r<r r r!Újoins zThread.joinTr9cCs0|j}|dkrn|j||ƒr,|jƒ|jƒdS)N)r‹r:r@r°)r,Úblockr<rPr r r!r³;szThread._wait_for_tstate_lockcCs|jS)N)r†)r,r r r!r0Is zThread.namecCst|ƒ|_dS)N)r…r†)r,r0r r r!r0TscCs|jS)N)rŠ)r,r r r!ÚidentYs zThread.identcCs(|js|jjƒrdS|jdƒ|jS)NF)rrŒrir³)r,r r r!r—es zThread.is_alivecCs|jS)N)r‰)r,r r r!rƒusz Thread.daemoncCs*|jstdƒ‚|jjƒr tdƒ‚||_dS)NzThread.__init__() not calledz)cannot set daemon status of active thread)rŽr?rŒrir‰)r,Údaemonicr r r!rƒ…s cCs|jS)N)rƒ)r,r r r!ÚisDaemonszThread.isDaemoncCs ||_dS)N)rƒ)r,r¸r r r!Ú setDaemonszThread.setDaemoncCs|jS)N)r0)r,r r r!ÚgetName“szThread.getNamecCs ||_dS)N)r0)r,r0r r r!ÚsetName–szThread.setName)NrI)TrI)rJr3r4rŽrÚexc_infor§r-rhr8ržrŸrœr¡r–r r°r²rµr³r~r0Úsetterr·r—ZisAliverƒr¹rºr»r¼r r r r!r÷s6 ,A# & c@s&eZdZddd„Zdd„Zdd„ZdS) rNcCsFtj|ƒ||_||_|dk r"|ng|_|dk r4|ni|_tƒ|_dS)N)rr-ÚintervalÚfunctionr%r&rÚfinished)r,r¿rÀr%r&r r r!r-¤s zTimer.__init__cCs|jjƒdS)N)rÁrj)r,r r r!Úcancel¬szTimer.cancelcCs6|jj|jƒ|jjƒs(|j|j|jŽ|jjƒdS)N)rÁr\r¿rirÀr%r&rj)r,r r r!rŸ°s z Timer.run)NN)rJr3r4r-rÂrŸr r r r!r›s c@seZdZdd„ZdS)Ú_MainThreadc CsHtj|ddd|jƒ|jjƒ|jƒt|t|j<WdQRXdS)NZ MainThreadF)r0rƒ) rr-r–rŒrjr¡r™r/rŠ)r,r r r!r-»s z_MainThread.__init__N)rJr3r4r-r r r r!rÃ¹srÃc@s.eZdZdd„Zdd„Zdd„Zd dd „ZdS)Ú_DummyThreadc CsDtj|tdƒdd|jjƒ|jƒt|t|j<WdQRXdS)NzDummy-%dT)r0rƒ) rr-r‚rŒrjr¡r™r/rŠ)r,r r r!r-Îs z_DummyThread.__init__cCsdS)Nr )r,r r r!r°Ösz_DummyThread._stopcCsdS)NTr )r,r r r!r—Ùsz_DummyThread.is_aliveNcCsdS)Nr )r,r<r r r!rµÝsz_DummyThread.join)N)rJr3r4r-r°r—rµr r r r!rÄÌsrÄcCs&y ttƒStk r tƒSXdS)N)r/r r1rÄr r r r!rãs c Cs tttƒttƒSQRXdS)N)r™rQr/ršr r r r!r ñscCsttjƒƒttjƒƒS)N)Úlistr/Úvaluesršr r r r!Ú _enumerateýsrÇc Cs(tttjƒƒttjƒƒSQRXdS)N)r™rÅr/rÆršr r r r!r s)rcCs8tj}|jƒtjƒtƒ}x|r2|jƒtƒ}qWdS)N)Ú_main_threadr‹r@r°Ú_pickSomeNonDaemonThreadrµ)ZtlockrAr r r!Ú _shutdownsrÊcCs(x"tƒD]}|jr|jƒr|SqWdS)N)r rƒr—)rAr r r!rÉ&srÉcCstS)N)rÈr r r r!r,s)Ú_local)rcCsžtƒai}tƒ}|at|ttƒƒ}|jtƒxF|D]>}||kr`|jdƒt ƒ}||_ |||<q4|jdƒ|jƒq4Wtj ƒtj ƒtj|ƒWdQRXdS)NTF)rr™rrÈrjrÇÚupdater’rhr rŠr°ršrkr/)Z new_activeZcurrentZthreadsZthreadr·r r r!Ú_after_fork=s& rÍ)r)LÚsysrÚ_threadZtimerrUrrWÚ tracebackrr¦Ú_weakrefsetrÚ itertoolsrr_rr+Ú_collectionsrrNÚImportErrorÚcollectionsÚ__all__Ústart_new_threadr›Ú allocate_lockr(r¢r Úerrorrrr#rMrrr"rrrr'r$rrrrrr?rÚ__next__r€r‚r™r/ršr’rrrÃrÄrZ currentThreadr ZactiveCountrÇr rrÈrÊrÉrrËrZ_threading_localrÍr r r r!ÚsŽ q9P&O '