|
Apache/2.2.15 (CentOS) Linux obd60-6c49958d75-2q7cw 5.4.0-174-generic #193-Ubuntu SMP Thu Mar 7 14:29:28 UTC 2024 x86_64 uid=48(apache) gid=48(apache) groups=48(apache) server ip : 104.21.65.202 | your ip : 10.244.126.0 safemode OFF > / usr / lib64 / python2.6 / |
| Filename | /usr/lib64/python2.6/threading.pyo |
| Size | 25.47 kb |
| Permission | rw-r--r-- |
| Owner | apache |
| Create time | 23-Dec-2025 17:41 |
| Last modified | 20-Jun-2019 19:45 |
| Last accessed | 22-Apr-2026 05:26 |
| Actions | edit | rename | delete | download (gzip) |
| View | text | code | image |
Ñò
§ÚêLc @ s6 d Z d d k Z y d d k Z Wn e j
o e i e =� n Xd d k Z d d k l Z d d k
l
Z l Z
d d k l Z d d k l Z d d d d
d d d
d d d d d d d d d d g Z e i Z e i Z e i Z e i Z [ e i d d e d d d d �e Z d e f d � � YZ! e" a# e" a$ d � Z% d! � Z& e Z' d" � Z( d# e! f d$ � � YZ) d% � Z* d& e! f d' � � YZ+ d( � Z, d) e! f d* � � YZ- d+ � Z. d, e- f d- � � YZ/ d. � Z0 d/ e! f d0 � � YZ1 d1 a2 d2 d3 � Z3 e � a4 h Z5 h Z6 d e! f d4 � � YZ7 d5 � Z8 d6 e7 f d7 � � YZ9 d8 e7 f d9 � � YZ: d: � Z; d; e7 f d< � � YZ< d= � Z= e= Z> d> � Z? e? Z@ d? � ZA d@ � ZB d dA k lC ZC e: � iD ZE y d dB k lF ZG Wn# e j
o d dC kH lG ZG n XdD � ZI dE � ZJ e dF j o eJ � n d S(G s; Thread module emulating a subset of Java's threading model.iÿÿÿÿN( t wraps( t timet sleep( t
format_exc( t dequet activeCountt active_countt Conditiont
currentThreadt current_threadt enumeratet Eventt Lockt RLockt Semaphoret BoundedSemaphoret Threadt Timert
setprofilet settracet localt
stack_sizet ignoret categoryt modulet threadingt messages
sys.exc_cleart _Verbosec B s e Z d d � Z d � Z RS( c C s d S( N( ( t selft verbose( ( s! /usr/lib64/python2.6/threading.pyt __init__J s c G s d S( N( ( R t args( ( s! /usr/lib64/python2.6/threading.pyt _noteL s N( t __name__t
__module__t NoneR R ( ( ( s! /usr/lib64/python2.6/threading.pyR I s c C s
| a d S( N( t
_profile_hook( t func( ( s! /usr/lib64/python2.6/threading.pyR T s c C s
| a d S( N( t _trace_hook( R% ( ( s! /usr/lib64/python2.6/threading.pyR X s c O s
t | | � S( N( t _RLock( R t kwargs( ( s! /usr/lib64/python2.6/threading.pyR
` s R' c B s\ e Z d d � Z d � Z d d � Z e Z d � Z d � Z d � Z d � Z
d � Z RS(
c C s2 t i | | � t � | _ d | _ d | _ d S( Ni ( R R t _allocate_lockt
_RLock__blockR# t
_RLock__ownert
_RLock__count( R R ( ( s! /usr/lib64/python2.6/threading.pyR e s c C sJ | i } y t | i } Wn t j
o n Xd | i i | | i f S( Ns <%s owner=%r count=%d>( R+ t _activet namet KeyErrort __class__R! R, ( R t owner( ( s! /usr/lib64/python2.6/threading.pyt __repr__k s i c C sa t � } | i | j o | i d | _ d S| i i | � } | o | | _ d | _ n | S( Ni ( t
_get_identR+ R, R* t acquire( R t blockingt met rc( ( s! /usr/lib64/python2.6/threading.pyR4 t s c C s\ | i t � j o t d � � n | i d | _ } | p d | _ | i i � n d S( Ns cannot release un-acquired locki ( R+ R3 t RuntimeErrorR, R# R* t release( R t count( ( s! /usr/lib64/python2.6/threading.pyR9 � s
c C s | i � d S( N( R9 ( R t tt vt tb( ( s! /usr/lib64/python2.6/threading.pyt __exit__� s c C s/ | \ } } | i i � | | _ | | _ d S( N( R* R4 R, R+ ( R t count_ownerR: R1 ( ( s! /usr/lib64/python2.6/threading.pyt _acquire_restore� s
c C s; | i } d | _ | i } d | _ | i i � | | f S( Ni ( R, R+ R# R* R9 ( R R: R1 ( ( s! /usr/lib64/python2.6/threading.pyt
_release_save¢ s
c C s | i t � j S( N( R+ R3 ( R ( ( s! /usr/lib64/python2.6/threading.pyt _is_owned¬ s N( R! R" R# R R2 R4 t __enter__R9 R> R@ RA RB ( ( ( s! /usr/lib64/python2.6/threading.pyR' c s
c O s
t | | � S( N( t
_Condition( R R( ( ( s! /usr/lib64/python2.6/threading.pyR ° s RD c B st e Z d d d � Z d � Z d � Z d � Z d � Z d � Z d � Z d d � Z
d d � Z d
� Z e Z
RS( c C sÊ t i | | � | d j o
t � } n | | _ | i | _ | i | _ y | i | _ Wn t j
o n Xy | i | _ Wn t j
o n Xy | i
| _
Wn t j
o n Xg | _ d S( N( R R R# R
t _Condition__lockR4 R9 RA t AttributeErrorR@ RB t _Condition__waiters( R t lockR ( ( s! /usr/lib64/python2.6/threading.pyR µ s&
c C s
| i i � S( N( RE RC ( R ( ( s! /usr/lib64/python2.6/threading.pyRC Î s c G s | i i | � S( N( RE R> ( R R ( ( s! /usr/lib64/python2.6/threading.pyR> Ñ s c C s d | i t | i � f S( Ns <Condition(%s, %d)>( RE t lenRG ( R ( ( s! /usr/lib64/python2.6/threading.pyR2 Ô s c C s | i i � d S( N( RE R9 ( R ( ( s! /usr/lib64/python2.6/threading.pyRA × s c C s | i i � d S( N( RE R4 ( R t x( ( s! /usr/lib64/python2.6/threading.pyR@ Ú s c C s- | i i d � o | i i � t St Sd S( Ni ( RE R4 R9 t Falset True( R ( ( s! /usr/lib64/python2.6/threading.pyRB Ý s
c C s1 | i � p t d � � n t � } | i � | i i | � | i � } zÐ | d j o | i � n² t � | } d } xf t o^ | i d � } | o Pn | t � } | d j o Pn t
| d | d � } t | � q� W| p. y | i i | � Wqt
j
o qXn Wd | i | � Xd S( Ns cannot wait on un-acquired lockgü©ñÒMb@?i i g������©?( RB R8 R) R4 RG t appendRA R# t _timeRL t mint _sleept removet
ValueErrorR@ ( R t timeoutt waitert saved_statet endtimet delayt gotitt remaining( ( s! /usr/lib64/python2.6/threading.pyt waitæ s:
i c C s¬ | i � p t d � � n | i } | | } | p d S| i d | | | d j o d p d � x? | D]7 } | i � y | i | � Wqm t j
o qm Xqm Wd S( Ns! cannot notify on un-acquired locks" %s.notify(): notifying %d waiter%si t st ( RB R8 RG R R9 RQ RR ( R t nRG t waitersRT ( ( s! /usr/lib64/python2.6/threading.pyt notify s
c C s | i t | i � � d S( N( R_ RI RG ( R ( ( s! /usr/lib64/python2.6/threading.pyt notifyAll" s N( R! R" R# R RC R> R2 RA R@ RB RZ R_ R` t
notify_all( ( ( s! /usr/lib64/python2.6/threading.pyRD ³ s * c O s
t | | � S( N( t
_Semaphore( R R( ( ( s! /usr/lib64/python2.6/threading.pyR ( s Rb c B s; e Z d d d � Z d d � Z e Z d � Z d � Z RS( i c C sL | d j o t d � � n t i | | � t t � � | _ | | _ d S( Ni s$ semaphore initial value must be >= 0( RR R R R R t _Semaphore__condt _Semaphore__value( R t valueR ( ( s! /usr/lib64/python2.6/threading.pyR / s
c C sk t } | i i � xD | i d j o | p Pn | i i � q W| i d | _ t } | i i � | S( Ni i ( RK Rc R4 Rd RZ RL R9 ( R R5 R7 ( ( s! /usr/lib64/python2.6/threading.pyR4 6 s
c C s; | i i � | i d | _ | i i � | i i � d S( Ni ( Rc R4 Rd R_ R9 ( R ( ( s! /usr/lib64/python2.6/threading.pyR9 K s
c C s | i � d S( N( R9 ( R R; R< R= ( ( s! /usr/lib64/python2.6/threading.pyR> T s N( R! R" R# R R4 RC R9 R> ( ( ( s! /usr/lib64/python2.6/threading.pyRb + s
c O s
t | | � S( N( t _BoundedSemaphore( R R( ( ( s! /usr/lib64/python2.6/threading.pyR X s Rf c B s& e Z d Z d d d � Z d � Z RS( s6 Semaphore that checks that # releases is <= # acquiresi c C s t i | | | � | | _ d S( N( Rb R t _initial_value( R Re R ( ( s! /usr/lib64/python2.6/threading.pyR ] s c C s- | i | i j o
t d � n t i | � S( Ns! Semaphore released too many times( Rd Rg RR Rb R9 ( R ( ( s! /usr/lib64/python2.6/threading.pyR9 a s
N( R! R" t __doc__R# R R9 ( ( ( s! /usr/lib64/python2.6/threading.pyRf [ s c O s
t | | � S( N( t _Event( R R( ( ( s! /usr/lib64/python2.6/threading.pyR g s Ri c B sA e Z d d � Z d � Z e Z d � Z d � Z d d � Z RS( c C s/ t i | | � t t � � | _ t | _ d S( N( R R R R t _Event__condRK t _Event__flag( R R ( ( s! /usr/lib64/python2.6/threading.pyR n s c C s | i S( N( Rk ( R ( ( s! /usr/lib64/python2.6/threading.pyt isSets s c C s< | i i � z t | _ | i i � Wd | i i � Xd S( N( Rj R4 RL Rk Ra R9 ( R ( ( s! /usr/lib64/python2.6/threading.pyt setx s
c C s/ | i i � z
t | _ Wd | i i � Xd S( N( Rj R4 RK Rk R9 ( R ( ( s! /usr/lib64/python2.6/threading.pyt clear� s
c C sD | i i � z" | i p | i i | � n Wd | i i � Xd S( N( Rj R4 Rk RZ R9 ( R RS ( ( s! /usr/lib64/python2.6/threading.pyRZ � s
N( R! R" R# R Rl t is_setRm Rn RZ ( ( ( s! /usr/lib64/python2.6/threading.pyRi j s i s Thread-%dc C s t d a | t S( Ni ( t _counter( t template( ( s! /usr/lib64/python2.6/threading.pyt _newname� s
c B s e Z e Z e i Z e i Z d d d d d d d � Z
d � Z d � Z d � Z
d � Z d � Z d � Z d � Z d � Z d � Z d d
� Z e d � � Z e i d � � Z e d
� � Z d � Z e Z e d � � Z e i d � � Z d � Z d � Z d � Z d � Z RS( c C s³ t i | | � | d j o
h } n | | _ t | p t � � | _ | | _ | | _ | i � | _
d | _ t � | _
t | _ t t � � | _ t | _ t i | _ d S( N( R R R# t _Thread__targett strRr t
_Thread__namet
_Thread__argst _Thread__kwargst _set_daemont _Thread__daemonict _Thread__identR t _Thread__startedRK t _Thread__stoppedR R t _Thread__blockRL t _Thread__initializedt _syst stderrt _Thread__stderr( R t groupt targetR. R R( R ( ( s! /usr/lib64/python2.6/threading.pyR ª s
c C s
t � i S( N( R t daemon( R ( ( s! /usr/lib64/python2.6/threading.pyRx ¾ s c C s� d } | i i � o
d } n | i o
d } n | i o | d 7} n | i d j o | d | i 7} n d | i i | i | f S( Nt initialt startedt stoppeds daemons %ss <%s(%s, %s)>( R{ Ro R| Ry Rz R# R0 R! Ru ( R t status( ( s! /usr/lib64/python2.6/threading.pyR2 Â s
c C sµ | i p t d � � n | i i � o t d � � n t i � | t | <t i � y t | i d � Wn5 t
j
o) t i i � z t | =Wd QX� n X| i i
� d S( Ns thread.__init__() not calleds thread already started( ( R~ R8 R{ Ro t _active_limbo_lockR4 t _limboR9 t _start_new_threadt _Thread__bootstrapt ExceptionR> RC RZ ( R ( ( s! /usr/lib64/python2.6/threading.pyt startÏ s
c C sB z( | i o | i | i | i � n Wd | ` | ` | ` Xd S( N( Rs Rv Rw ( R ( ( s! /usr/lib64/python2.6/threading.pyt runá s
c C s; y | i � Wn& | i o t d j o d S� n Xd S( N( t _Thread__bootstrap_innerRy R R# ( R ( ( s! /usr/lib64/python2.6/threading.pyt __bootstrapê s
c C s t � | _ d S( N( R3 Rz ( R ( ( s! /usr/lib64/python2.6/threading.pyt
_set_identþ s c C så z£| i � | i i � t i � | t | i <t | =t i � t o! | i
d | � t i t � n t
o! | i
d | � t i t
� n zy | i � Wní t j
o nÜ t o$ t i i d | i t � f � q�| i � \ } } } z� | i d | i d IJ| i d IJxD | o< | i d | i i i | i | i i i f IJ| i } q&W| i d | | f IJWd ~ ~ ~ Xn XWd | i � XWd t i i � z& | i � y t t! � =Wn n XWd QXXd S( Ns( %s.__bootstrap(): registering trace hooks* %s.__bootstrap(): registering profile hooks Exception in thread %s:
%s
s Exception in thread s2 (most likely raised during interpreter shutdown):s" Traceback (most recent call last):s File "%s", line %s, in %ss %s: %s(" R� R{ Rm R� R4 R- Rz R� R9 R& R R R R$ R R� t
SystemExitR� t writeR. t _format_exct _Thread__exc_infoR� t tb_framet f_codet co_filenamet tb_linenot co_namet tb_nextt _Thread__exc_clearR> RC t
_Thread__stopR3 ( R t exc_typet exc_valuet exc_tb( ( s! /usr/lib64/python2.6/threading.pyt __bootstrap_inner s^
c C s4 | i i � t | _ | i i � | i i � d S( N( R} R4 RL R| Ra R9 ( R ( ( s! /usr/lib64/python2.6/threading.pyt __stopL s
c C sW y& t i i � z t t � =Wd QXWn* t j
o d t i j o � qS n Xd S( sA Remove current thread from the dict of currently running threads.Nt dummy_threading( R� R> RC R- R3 R/ R t modules( R ( ( s! /usr/lib64/python2.6/threading.pyt __deleteR s c C sþ | i p t d � � n | i i � p t d � � n | t � j o t d � � n | i i � z� | d j o# xn | i p | i i � qz WnO t
� | } x> | i p3 | t
� } | d j o Pn | i i | � qª WWd | i i � Xd S( Ns Thread.__init__() not calleds' cannot join thread before it is starteds cannot join current threadi ( R~ R8 R{ Ro R R} R4 R# R| RZ RN R9 ( R RS t deadlineRW ( ( s! /usr/lib64/python2.6/threading.pyt joinu s,
c C s | i S( N( Ru ( R ( ( s! /usr/lib64/python2.6/threading.pyR. � s c C s t | � | _ d S( N( Rt Ru ( R R. ( ( s! /usr/lib64/python2.6/threading.pyR. � s c C s | i S( N( Rz ( R ( ( s! /usr/lib64/python2.6/threading.pyt ident s c C s | i i � o | i S( N( R{ Ro R| ( R ( ( s! /usr/lib64/python2.6/threading.pyt isAlive¥ s c C s | i S( N( Ry ( R ( ( s! /usr/lib64/python2.6/threading.pyR� « s c C sG | i p t d � � n | i i � o t d � � n | | _ d S( Ns Thread.__init__() not calleds) cannot set daemon status of active thread( R~ R8 R{ Ro Ry ( R t daemonic( ( s! /usr/lib64/python2.6/threading.pyR� ° s
c C s | i S( N( R� ( R ( ( s! /usr/lib64/python2.6/threading.pyt isDaemon¸ s c C s
| | _ d S( N( R� ( R R« ( ( s! /usr/lib64/python2.6/threading.pyt setDaemon» s c C s | i S( N( R. ( R ( ( s! /usr/lib64/python2.6/threading.pyt getName¾ s c C s
| | _ d S( N( R. ( R R. ( ( s! /usr/lib64/python2.6/threading.pyt setNameÁ s N( ( R! R" RK R~ R t exc_infoR� t exc_clearR� R# R Rx R2 R� R� R� R� R� R� t _Thread__deleteR¨ t propertyR. t setterR© Rª t is_aliveR� R¬ R R® R¯ ( ( ( s! /usr/lib64/python2.6/threading.pyR � s4
K # ! c O s
t | | � S( N( t _Timer( R R( ( ( s! /usr/lib64/python2.6/threading.pyR Æ s R¶ c B s/ e Z d Z g h d � Z d � Z d � Z RS( s² Call a function after a specified number of seconds:
t = Timer(30.0, f, args=[], kwargs={})
t.start()
t.cancel() # stop the timer's action if it's still waiting
c C sA t i | � | | _ | | _ | | _ | | _ t � | _ d S( N( R R t intervalt functionR R( R t finished( R R· R¸ R R( ( ( s! /usr/lib64/python2.6/threading.pyR Ñ s
c C s | i i � d S( s( Stop the timer if it hasn't finished yetN( R¹ Rm ( R ( ( s! /usr/lib64/python2.6/threading.pyt cancelÙ s c C sN | i i | i � | i i � p | i | i | i � n | i i � d S( N( R¹ RZ R· Ro R¸ R R( Rm ( R ( ( s! /usr/lib64/python2.6/threading.pyR� Ý s ( R! R" Rh R Rº R� ( ( ( s! /usr/lib64/python2.6/threading.pyR¶ É s t _MainThreadc B s# e Z d � Z d � Z d � Z RS( c C sO t i | d d �| i i � | i � t i � | t t � <t i � d S( NR. t
MainThread(
R R R{ Rm R� R� R4 R- R3 R9 ( R ( ( s! /usr/lib64/python2.6/threading.pyR è s
c C s t S( N( RK ( R ( ( s! /usr/lib64/python2.6/threading.pyRx ð s c C sN | i � t � } | o n x | o | i � t � } q! W| i � d S( N( R� t _pickSomeNonDaemonThreadR¨ R² ( R R; ( ( s! /usr/lib64/python2.6/threading.pyt _exitfuncó s
( R! R" R Rx R¾ ( ( ( s! /usr/lib64/python2.6/threading.pyR» æ s c C s5 x. t � D]# } | i o | i � o | Sq
Wd S( N( R
R� Rµ R# ( R; ( ( s! /usr/lib64/python2.6/threading.pyR½ s
t _DummyThreadc B s& e Z d � Z d � Z d d � Z RS( c C s[ t i | d t d � �| ` | i i � | i � t i � | t t
� <t i � d S( NR. s Dummy-%d( R R Rr R} R{ Rm R� R� R4 R- R3 R9 ( R ( ( s! /usr/lib64/python2.6/threading.pyR s
c C s t S( N( RL ( R ( ( s! /usr/lib64/python2.6/threading.pyRx s c C s d S( N( ( R RS ( ( s! /usr/lib64/python2.6/threading.pyR¨ " s N( R! R" R Rx R# R¨ ( ( ( s! /usr/lib64/python2.6/threading.pyR¿ s c C s- y t t � SWn t j
o t � SXd S( N( R- R3 R/ R¿ ( ( ( s! /usr/lib64/python2.6/threading.pyR ( s c C s. t i � t t � t t � } t i � | S( N( R� R4 RI R- R� R9 ( R: ( ( s! /usr/lib64/python2.6/threading.pyR 1 s
c C s t i � t i � S( N( R- t valuesR� ( ( ( s! /usr/lib64/python2.6/threading.pyt
_enumerate9 s c C s. t i � t i � t i � } t i � | S( N( R� R4 R- RÀ R� R9 ( t active( ( s! /usr/lib64/python2.6/threading.pyR
= s
( R ( t _local( R c C s¢ t � a h } t � } t i i � zr xJ t i � D]< } | | j o t � } | | _ | | | <q7 t | _
q7 Wt i � t i � t i
| � Wd QXd S( N( R) R� R R> RC R- t
itervaluesR3 Rz RL R| R� Rn t update( t
new_activet currentt threadR© ( ( s! /usr/lib64/python2.6/threading.pyt _after_forkT s
c C s d t f d � � Y} d t f d � � Y} d t f d � � Y} d } d } d } | | � } g } xA t | � D]3 } | | | � } d
| d | _ | i | � qs W| | | | � }
x" | D] } | i � t d � qÄ W|
i � x | D] } | i � qó W|
i � d S(
Nt BoundedQueuec B s# e Z d � Z d � Z d � Z RS( c S sV t i | � t � | _ t | i � | _ t | i � | _ | | _ t � | _ d S( N(
R R R
t monR R7 t wct limitR t queue( R RÍ ( ( s! /usr/lib64/python2.6/threading.pyR | s
c S s� | i i � x; t | i � | i j o! | i d | � | i i � q W| i i | � | i d | t | i � � | i i
� | i i � d S( Ns put(%s): queue fulls put(%s): appended, length now %d( RË R4 RI RÎ RÍ R RÌ RZ RM R7 R_ R9 ( R t item( ( s! /usr/lib64/python2.6/threading.pyt put� s
c S s� | i i � x) | i p | i d � | i i � q W| i i � } | i d | t | i � � | i i � | i i
� | S( Ns get(): queue emptys get(): got %s, %d left( RË R4 RÎ R R7 RZ t popleftRI RÌ R_ R9 ( R RÏ ( ( s! /usr/lib64/python2.6/threading.pyt get� s
( R! R" R RÐ RÒ ( ( ( s! /usr/lib64/python2.6/threading.pyRÊ z s t ProducerThreadc B s e Z d � Z d � Z RS( c S s) t i | d d �| | _ | | _ d S( NR. t Producer( R R RÎ t quota( R RÎ RÕ ( ( s! /usr/lib64/python2.6/threading.pyR � s c S sj d d k l } d } xM | | i j o< | d } | i i d | i | f � t | � d � q Wd S( Niÿÿÿÿ( t randomi i s %s.%dgñhã�µøä>( RÖ RÕ RÎ RÐ R. RP ( R RÖ t counter( ( s! /usr/lib64/python2.6/threading.pyR� ¡ s
( R! R" R R� ( ( ( s! /usr/lib64/python2.6/threading.pyRÓ � s t ConsumerThreadc B s e Z d � Z d � Z RS( c S s) t i | d d �| | _ | | _ d S( NR. t Consumer( R R RÎ R: ( R RÎ R: ( ( s! /usr/lib64/python2.6/threading.pyR ¬ s c S s@ x9 | i d j o( | i i � } | GH| i d | _ q Wd S( Ni i ( R: RÎ RÒ ( R RÏ ( ( s! /usr/lib64/python2.6/threading.pyR� ± s
( R! R" R R� ( ( ( s! /usr/lib64/python2.6/threading.pyRØ ª s i i i s Producer-%di g�íµ ÷Æ°>( R R t rangeR. RM R� RP R¨ ( RÊ RÓ RØ t NPt QLt NIt Qt Pt iR; t C( ( s! /usr/lib64/python2.6/threading.pyt _testx s.
t __main__(K Rh t sysR RÈ t ImportErrorR¥ R! t warningst functoolsR R RN R RP t tracebackR R� t collectionsR t __all__t start_new_threadR� t
allocate_lockR) t get_identR3 t errort ThreadErrort filterwarningst DeprecationWarningRK t _VERBOSEt objectR R# R$ R& R R R R
R' R RD R Rb R Rf R Ri Rp Rr R� R- R� R R R¶ R» R½ R¿ R R R R RÁ R
R R¾ t _shutdownRÃ R t _threading_localRÉ Râ ( ( ( s! /usr/lib64/python2.6/threading.pyt <module> s�
M u - & ÿ ) $ R
§ÚêLc @ s6 d Z d d k Z y d d k Z Wn e j
o e i e =� n Xd d k Z d d k l Z d d k
l
Z l Z
d d k l Z d d k l Z d d d d
d d d
d d d d d d d d d d g Z e i Z e i Z e i Z e i Z [ e i d d e d d d d �e Z d e f d � � YZ! e" a# e" a$ d � Z% d! � Z& e Z' d" � Z( d# e! f d$ � � YZ) d% � Z* d& e! f d' � � YZ+ d( � Z, d) e! f d* � � YZ- d+ � Z. d, e- f d- � � YZ/ d. � Z0 d/ e! f d0 � � YZ1 d1 a2 d2 d3 � Z3 e � a4 h Z5 h Z6 d e! f d4 � � YZ7 d5 � Z8 d6 e7 f d7 � � YZ9 d8 e7 f d9 � � YZ: d: � Z; d; e7 f d< � � YZ< d= � Z= e= Z> d> � Z? e? Z@ d? � ZA d@ � ZB d dA k lC ZC e: � iD ZE y d dB k lF ZG Wn# e j
o d dC kH lG ZG n XdD � ZI dE � ZJ e dF j o eJ � n d S(G s; Thread module emulating a subset of Java's threading model.iÿÿÿÿN( t wraps( t timet sleep( t
format_exc( t dequet activeCountt active_countt Conditiont
currentThreadt current_threadt enumeratet Eventt Lockt RLockt Semaphoret BoundedSemaphoret Threadt Timert
setprofilet settracet localt
stack_sizet ignoret categoryt modulet threadingt messages
sys.exc_cleart _Verbosec B s e Z d d � Z d � Z RS( c C s d S( N( ( t selft verbose( ( s! /usr/lib64/python2.6/threading.pyt __init__J s c G s d S( N( ( R t args( ( s! /usr/lib64/python2.6/threading.pyt _noteL s N( t __name__t
__module__t NoneR R ( ( ( s! /usr/lib64/python2.6/threading.pyR I s c C s
| a d S( N( t
_profile_hook( t func( ( s! /usr/lib64/python2.6/threading.pyR T s c C s
| a d S( N( t _trace_hook( R% ( ( s! /usr/lib64/python2.6/threading.pyR X s c O s
t | | � S( N( t _RLock( R t kwargs( ( s! /usr/lib64/python2.6/threading.pyR
` s R' c B s\ e Z d d � Z d � Z d d � Z e Z d � Z d � Z d � Z d � Z
d � Z RS(
c C s2 t i | | � t � | _ d | _ d | _ d S( Ni ( R R t _allocate_lockt
_RLock__blockR# t
_RLock__ownert
_RLock__count( R R ( ( s! /usr/lib64/python2.6/threading.pyR e s c C sJ | i } y t | i } Wn t j
o n Xd | i i | | i f S( Ns <%s owner=%r count=%d>( R+ t _activet namet KeyErrort __class__R! R, ( R t owner( ( s! /usr/lib64/python2.6/threading.pyt __repr__k s i c C sa t � } | i | j o | i d | _ d S| i i | � } | o | | _ d | _ n | S( Ni ( t
_get_identR+ R, R* t acquire( R t blockingt met rc( ( s! /usr/lib64/python2.6/threading.pyR4 t s c C s\ | i t � j o t d � � n | i d | _ } | p d | _ | i i � n d S( Ns cannot release un-acquired locki ( R+ R3 t RuntimeErrorR, R# R* t release( R t count( ( s! /usr/lib64/python2.6/threading.pyR9 � s
c C s | i � d S( N( R9 ( R t tt vt tb( ( s! /usr/lib64/python2.6/threading.pyt __exit__� s c C s/ | \ } } | i i � | | _ | | _ d S( N( R* R4 R, R+ ( R t count_ownerR: R1 ( ( s! /usr/lib64/python2.6/threading.pyt _acquire_restore� s
c C s; | i } d | _ | i } d | _ | i i � | | f S( Ni ( R, R+ R# R* R9 ( R R: R1 ( ( s! /usr/lib64/python2.6/threading.pyt
_release_save¢ s
c C s | i t � j S( N( R+ R3 ( R ( ( s! /usr/lib64/python2.6/threading.pyt _is_owned¬ s N( R! R" R# R R2 R4 t __enter__R9 R> R@ RA RB ( ( ( s! /usr/lib64/python2.6/threading.pyR' c s
c O s
t | | � S( N( t
_Condition( R R( ( ( s! /usr/lib64/python2.6/threading.pyR ° s RD c B st e Z d d d � Z d � Z d � Z d � Z d � Z d � Z d � Z d d � Z
d d � Z d
� Z e Z
RS( c C sÊ t i | | � | d j o
t � } n | | _ | i | _ | i | _ y | i | _ Wn t j
o n Xy | i | _ Wn t j
o n Xy | i
| _
Wn t j
o n Xg | _ d S( N( R R R# R
t _Condition__lockR4 R9 RA t AttributeErrorR@ RB t _Condition__waiters( R t lockR ( ( s! /usr/lib64/python2.6/threading.pyR µ s&
c C s
| i i � S( N( RE RC ( R ( ( s! /usr/lib64/python2.6/threading.pyRC Î s c G s | i i | � S( N( RE R> ( R R ( ( s! /usr/lib64/python2.6/threading.pyR> Ñ s c C s d | i t | i � f S( Ns <Condition(%s, %d)>( RE t lenRG ( R ( ( s! /usr/lib64/python2.6/threading.pyR2 Ô s c C s | i i � d S( N( RE R9 ( R ( ( s! /usr/lib64/python2.6/threading.pyRA × s c C s | i i � d S( N( RE R4 ( R t x( ( s! /usr/lib64/python2.6/threading.pyR@ Ú s c C s- | i i d � o | i i � t St Sd S( Ni ( RE R4 R9 t Falset True( R ( ( s! /usr/lib64/python2.6/threading.pyRB Ý s
c C s1 | i � p t d � � n t � } | i � | i i | � | i � } zÐ | d j o | i � n² t � | } d } xf t o^ | i d � } | o Pn | t � } | d j o Pn t
| d | d � } t | � q� W| p. y | i i | � Wqt
j
o qXn Wd | i | � Xd S( Ns cannot wait on un-acquired lockgü©ñÒMb@?i i g������©?( RB R8 R) R4 RG t appendRA R# t _timeRL t mint _sleept removet
ValueErrorR@ ( R t timeoutt waitert saved_statet endtimet delayt gotitt remaining( ( s! /usr/lib64/python2.6/threading.pyt waitæ s:
i c C s¬ | i � p t d � � n | i } | | } | p d S| i d | | | d j o d p d � x? | D]7 } | i � y | i | � Wqm t j
o qm Xqm Wd S( Ns! cannot notify on un-acquired locks" %s.notify(): notifying %d waiter%si t st ( RB R8 RG R R9 RQ RR ( R t nRG t waitersRT ( ( s! /usr/lib64/python2.6/threading.pyt notify s
c C s | i t | i � � d S( N( R_ RI RG ( R ( ( s! /usr/lib64/python2.6/threading.pyt notifyAll" s N( R! R" R# R RC R> R2 RA R@ RB RZ R_ R` t
notify_all( ( ( s! /usr/lib64/python2.6/threading.pyRD ³ s * c O s
t | | � S( N( t
_Semaphore( R R( ( ( s! /usr/lib64/python2.6/threading.pyR ( s Rb c B s; e Z d d d � Z d d � Z e Z d � Z d � Z RS( i c C sL | d j o t d � � n t i | | � t t � � | _ | | _ d S( Ni s$ semaphore initial value must be >= 0( RR R R R R t _Semaphore__condt _Semaphore__value( R t valueR ( ( s! /usr/lib64/python2.6/threading.pyR / s
c C sk t } | i i � xD | i d j o | p Pn | i i � q W| i d | _ t } | i i � | S( Ni i ( RK Rc R4 Rd RZ RL R9 ( R R5 R7 ( ( s! /usr/lib64/python2.6/threading.pyR4 6 s
c C s; | i i � | i d | _ | i i � | i i � d S( Ni ( Rc R4 Rd R_ R9 ( R ( ( s! /usr/lib64/python2.6/threading.pyR9 K s
c C s | i � d S( N( R9 ( R R; R< R= ( ( s! /usr/lib64/python2.6/threading.pyR> T s N( R! R" R# R R4 RC R9 R> ( ( ( s! /usr/lib64/python2.6/threading.pyRb + s
c O s
t | | � S( N( t _BoundedSemaphore( R R( ( ( s! /usr/lib64/python2.6/threading.pyR X s Rf c B s& e Z d Z d d d � Z d � Z RS( s6 Semaphore that checks that # releases is <= # acquiresi c C s t i | | | � | | _ d S( N( Rb R t _initial_value( R Re R ( ( s! /usr/lib64/python2.6/threading.pyR ] s c C s- | i | i j o
t d � n t i | � S( Ns! Semaphore released too many times( Rd Rg RR Rb R9 ( R ( ( s! /usr/lib64/python2.6/threading.pyR9 a s
N( R! R" t __doc__R# R R9 ( ( ( s! /usr/lib64/python2.6/threading.pyRf [ s c O s
t | | � S( N( t _Event( R R( ( ( s! /usr/lib64/python2.6/threading.pyR g s Ri c B sA e Z d d � Z d � Z e Z d � Z d � Z d d � Z RS( c C s/ t i | | � t t � � | _ t | _ d S( N( R R R R t _Event__condRK t _Event__flag( R R ( ( s! /usr/lib64/python2.6/threading.pyR n s c C s | i S( N( Rk ( R ( ( s! /usr/lib64/python2.6/threading.pyt isSets s c C s< | i i � z t | _ | i i � Wd | i i � Xd S( N( Rj R4 RL Rk Ra R9 ( R ( ( s! /usr/lib64/python2.6/threading.pyt setx s
c C s/ | i i � z
t | _ Wd | i i � Xd S( N( Rj R4 RK Rk R9 ( R ( ( s! /usr/lib64/python2.6/threading.pyt clear� s
c C sD | i i � z" | i p | i i | � n Wd | i i � Xd S( N( Rj R4 Rk RZ R9 ( R RS ( ( s! /usr/lib64/python2.6/threading.pyRZ � s
N( R! R" R# R Rl t is_setRm Rn RZ ( ( ( s! /usr/lib64/python2.6/threading.pyRi j s i s Thread-%dc C s t d a | t S( Ni ( t _counter( t template( ( s! /usr/lib64/python2.6/threading.pyt _newname� s
c B s e Z e Z e i Z e i Z d d d d d d d � Z
d � Z d � Z d � Z
d � Z d � Z d � Z d � Z d � Z d � Z d d
� Z e d � � Z e i d � � Z e d
� � Z d � Z e Z e d � � Z e i d � � Z d � Z d � Z d � Z d � Z RS( c C s³ t i | | � | d j o
h } n | | _ t | p t � � | _ | | _ | | _ | i � | _
d | _ t � | _
t | _ t t � � | _ t | _ t i | _ d S( N( R R R# t _Thread__targett strRr t
_Thread__namet
_Thread__argst _Thread__kwargst _set_daemont _Thread__daemonict _Thread__identR t _Thread__startedRK t _Thread__stoppedR R t _Thread__blockRL t _Thread__initializedt _syst stderrt _Thread__stderr( R t groupt targetR. R R( R ( ( s! /usr/lib64/python2.6/threading.pyR ª s
c C s
t � i S( N( R t daemon( R ( ( s! /usr/lib64/python2.6/threading.pyRx ¾ s c C s� d } | i i � o
d } n | i o
d } n | i o | d 7} n | i d j o | d | i 7} n d | i i | i | f S( Nt initialt startedt stoppeds daemons %ss <%s(%s, %s)>( R{ Ro R| Ry Rz R# R0 R! Ru ( R t status( ( s! /usr/lib64/python2.6/threading.pyR2 Â s
c C sµ | i p t d � � n | i i � o t d � � n t i � | t | <t i � y t | i d � Wn5 t
j
o) t i i � z t | =Wd QX� n X| i i
� d S( Ns thread.__init__() not calleds thread already started( ( R~ R8 R{ Ro t _active_limbo_lockR4 t _limboR9 t _start_new_threadt _Thread__bootstrapt ExceptionR> RC RZ ( R ( ( s! /usr/lib64/python2.6/threading.pyt startÏ s
c C sB z( | i o | i | i | i � n Wd | ` | ` | ` Xd S( N( Rs Rv Rw ( R ( ( s! /usr/lib64/python2.6/threading.pyt runá s
c C s; y | i � Wn& | i o t d j o d S� n Xd S( N( t _Thread__bootstrap_innerRy R R# ( R ( ( s! /usr/lib64/python2.6/threading.pyt __bootstrapê s
c C s t � | _ d S( N( R3 Rz ( R ( ( s! /usr/lib64/python2.6/threading.pyt
_set_identþ s c C så z£| i � | i i � t i � | t | i <t | =t i � t o! | i
d | � t i t � n t
o! | i
d | � t i t
� n zy | i � Wní t j
o nÜ t o$ t i i d | i t � f � q�| i � \ } } } z� | i d | i d IJ| i d IJxD | o< | i d | i i i | i | i i i f IJ| i } q&W| i d | | f IJWd ~ ~ ~ Xn XWd | i � XWd t i i � z& | i � y t t! � =Wn n XWd QXXd S( Ns( %s.__bootstrap(): registering trace hooks* %s.__bootstrap(): registering profile hooks Exception in thread %s:
%s
s Exception in thread s2 (most likely raised during interpreter shutdown):s" Traceback (most recent call last):s File "%s", line %s, in %ss %s: %s(" R� R{ Rm R� R4 R- Rz R� R9 R& R R R R$ R R� t
SystemExitR� t writeR. t _format_exct _Thread__exc_infoR� t tb_framet f_codet co_filenamet tb_linenot co_namet tb_nextt _Thread__exc_clearR> RC t
_Thread__stopR3 ( R t exc_typet exc_valuet exc_tb( ( s! /usr/lib64/python2.6/threading.pyt __bootstrap_inner s^
c C s4 | i i � t | _ | i i � | i i � d S( N( R} R4 RL R| Ra R9 ( R ( ( s! /usr/lib64/python2.6/threading.pyt __stopL s
c C sW y& t i i � z t t � =Wd QXWn* t j
o d t i j o � qS n Xd S( sA Remove current thread from the dict of currently running threads.Nt dummy_threading( R� R> RC R- R3 R/ R t modules( R ( ( s! /usr/lib64/python2.6/threading.pyt __deleteR s c C sþ | i p t d � � n | i i � p t d � � n | t � j o t d � � n | i i � z� | d j o# xn | i p | i i � qz WnO t
� | } x> | i p3 | t
� } | d j o Pn | i i | � qª WWd | i i � Xd S( Ns Thread.__init__() not calleds' cannot join thread before it is starteds cannot join current threadi ( R~ R8 R{ Ro R R} R4 R# R| RZ RN R9 ( R RS t deadlineRW ( ( s! /usr/lib64/python2.6/threading.pyt joinu s,
c C s | i S( N( Ru ( R ( ( s! /usr/lib64/python2.6/threading.pyR. � s c C s t | � | _ d S( N( Rt Ru ( R R. ( ( s! /usr/lib64/python2.6/threading.pyR. � s c C s | i S( N( Rz ( R ( ( s! /usr/lib64/python2.6/threading.pyt ident s c C s | i i � o | i S( N( R{ Ro R| ( R ( ( s! /usr/lib64/python2.6/threading.pyt isAlive¥ s c C s | i S( N( Ry ( R ( ( s! /usr/lib64/python2.6/threading.pyR� « s c C sG | i p t d � � n | i i � o t d � � n | | _ d S( Ns Thread.__init__() not calleds) cannot set daemon status of active thread( R~ R8 R{ Ro Ry ( R t daemonic( ( s! /usr/lib64/python2.6/threading.pyR� ° s
c C s | i S( N( R� ( R ( ( s! /usr/lib64/python2.6/threading.pyt isDaemon¸ s c C s
| | _ d S( N( R� ( R R« ( ( s! /usr/lib64/python2.6/threading.pyt setDaemon» s c C s | i S( N( R. ( R ( ( s! /usr/lib64/python2.6/threading.pyt getName¾ s c C s
| | _ d S( N( R. ( R R. ( ( s! /usr/lib64/python2.6/threading.pyt setNameÁ s N( ( R! R" RK R~ R t exc_infoR� t exc_clearR� R# R Rx R2 R� R� R� R� R� R� t _Thread__deleteR¨ t propertyR. t setterR© Rª t is_aliveR� R¬ R R® R¯ ( ( ( s! /usr/lib64/python2.6/threading.pyR � s4
K # ! c O s
t | | � S( N( t _Timer( R R( ( ( s! /usr/lib64/python2.6/threading.pyR Æ s R¶ c B s/ e Z d Z g h d � Z d � Z d � Z RS( s² Call a function after a specified number of seconds:
t = Timer(30.0, f, args=[], kwargs={})
t.start()
t.cancel() # stop the timer's action if it's still waiting
c C sA t i | � | | _ | | _ | | _ | | _ t � | _ d S( N( R R t intervalt functionR R( R t finished( R R· R¸ R R( ( ( s! /usr/lib64/python2.6/threading.pyR Ñ s
c C s | i i � d S( s( Stop the timer if it hasn't finished yetN( R¹ Rm ( R ( ( s! /usr/lib64/python2.6/threading.pyt cancelÙ s c C sN | i i | i � | i i � p | i | i | i � n | i i � d S( N( R¹ RZ R· Ro R¸ R R( Rm ( R ( ( s! /usr/lib64/python2.6/threading.pyR� Ý s ( R! R" Rh R Rº R� ( ( ( s! /usr/lib64/python2.6/threading.pyR¶ É s t _MainThreadc B s# e Z d � Z d � Z d � Z RS( c C sO t i | d d �| i i � | i � t i � | t t � <t i � d S( NR. t
MainThread(
R R R{ Rm R� R� R4 R- R3 R9 ( R ( ( s! /usr/lib64/python2.6/threading.pyR è s
c C s t S( N( RK ( R ( ( s! /usr/lib64/python2.6/threading.pyRx ð s c C sN | i � t � } | o n x | o | i � t � } q! W| i � d S( N( R� t _pickSomeNonDaemonThreadR¨ R² ( R R; ( ( s! /usr/lib64/python2.6/threading.pyt _exitfuncó s
( R! R" R Rx R¾ ( ( ( s! /usr/lib64/python2.6/threading.pyR» æ s c C s5 x. t � D]# } | i o | i � o | Sq
Wd S( N( R
R� Rµ R# ( R; ( ( s! /usr/lib64/python2.6/threading.pyR½ s
t _DummyThreadc B s& e Z d � Z d � Z d d � Z RS( c C s[ t i | d t d � �| ` | i i � | i � t i � | t t
� <t i � d S( NR. s Dummy-%d( R R Rr R} R{ Rm R� R� R4 R- R3 R9 ( R ( ( s! /usr/lib64/python2.6/threading.pyR s
c C s t S( N( RL ( R ( ( s! /usr/lib64/python2.6/threading.pyRx s c C s d S( N( ( R RS ( ( s! /usr/lib64/python2.6/threading.pyR¨ " s N( R! R" R Rx R# R¨ ( ( ( s! /usr/lib64/python2.6/threading.pyR¿ s c C s- y t t � SWn t j
o t � SXd S( N( R- R3 R/ R¿ ( ( ( s! /usr/lib64/python2.6/threading.pyR ( s c C s. t i � t t � t t � } t i � | S( N( R� R4 RI R- R� R9 ( R: ( ( s! /usr/lib64/python2.6/threading.pyR 1 s
c C s t i � t i � S( N( R- t valuesR� ( ( ( s! /usr/lib64/python2.6/threading.pyt
_enumerate9 s c C s. t i � t i � t i � } t i � | S( N( R� R4 R- RÀ R� R9 ( t active( ( s! /usr/lib64/python2.6/threading.pyR
= s
( R ( t _local( R c C s¢ t � a h } t � } t i i � zr xJ t i � D]< } | | j o t � } | | _ | | | <q7 t | _
q7 Wt i � t i � t i
| � Wd QXd S( N( R) R� R R> RC R- t
itervaluesR3 Rz RL R| R� Rn t update( t
new_activet currentt threadR© ( ( s! /usr/lib64/python2.6/threading.pyt _after_forkT s
c C s d t f d � � Y} d t f d � � Y} d t f d � � Y} d } d } d } | | � } g } xA t | � D]3 } | | | � } d
| d | _ | i | � qs W| | | | � }
x" | D] } | i � t d � qÄ W|
i � x | D] } | i � qó W|
i � d S(
Nt BoundedQueuec B s# e Z d � Z d � Z d � Z RS( c S sV t i | � t � | _ t | i � | _ t | i � | _ | | _ t � | _ d S( N(
R R R
t monR R7 t wct limitR t queue( R RÍ ( ( s! /usr/lib64/python2.6/threading.pyR | s
c S s� | i i � x; t | i � | i j o! | i d | � | i i � q W| i i | � | i d | t | i � � | i i
� | i i � d S( Ns put(%s): queue fulls put(%s): appended, length now %d( RË R4 RI RÎ RÍ R RÌ RZ RM R7 R_ R9 ( R t item( ( s! /usr/lib64/python2.6/threading.pyt put� s
c S s� | i i � x) | i p | i d � | i i � q W| i i � } | i d | t | i � � | i i � | i i
� | S( Ns get(): queue emptys get(): got %s, %d left( RË R4 RÎ R R7 RZ t popleftRI RÌ R_ R9 ( R RÏ ( ( s! /usr/lib64/python2.6/threading.pyt get� s
( R! R" R RÐ RÒ ( ( ( s! /usr/lib64/python2.6/threading.pyRÊ z s t ProducerThreadc B s e Z d � Z d � Z RS( c S s) t i | d d �| | _ | | _ d S( NR. t Producer( R R RÎ t quota( R RÎ RÕ ( ( s! /usr/lib64/python2.6/threading.pyR � s c S sj d d k l } d } xM | | i j o< | d } | i i d | i | f � t | � d � q Wd S( Niÿÿÿÿ( t randomi i s %s.%dgñhã�µøä>( RÖ RÕ RÎ RÐ R. RP ( R RÖ t counter( ( s! /usr/lib64/python2.6/threading.pyR� ¡ s
( R! R" R R� ( ( ( s! /usr/lib64/python2.6/threading.pyRÓ � s t ConsumerThreadc B s e Z d � Z d � Z RS( c S s) t i | d d �| | _ | | _ d S( NR. t Consumer( R R RÎ R: ( R RÎ R: ( ( s! /usr/lib64/python2.6/threading.pyR ¬ s c S s@ x9 | i d j o( | i i � } | GH| i d | _ q Wd S( Ni i ( R: RÎ RÒ ( R RÏ ( ( s! /usr/lib64/python2.6/threading.pyR� ± s
( R! R" R R� ( ( ( s! /usr/lib64/python2.6/threading.pyRØ ª s i i i s Producer-%di g�íµ ÷Æ°>( R R t rangeR. RM R� RP R¨ ( RÊ RÓ RØ t NPt QLt NIt Qt Pt iR; t C( ( s! /usr/lib64/python2.6/threading.pyt _testx s.
t __main__(K Rh t sysR RÈ t ImportErrorR¥ R! t warningst functoolsR R RN R RP t tracebackR R� t collectionsR t __all__t start_new_threadR� t
allocate_lockR) t get_identR3 t errort ThreadErrort filterwarningst DeprecationWarningRK t _VERBOSEt objectR R# R$ R& R R R R
R' R RD R Rb R Rf R Ri Rp Rr R� R- R� R R R¶ R» R½ R¿ R R R R RÁ R
R R¾ t _shutdownRÃ R t _threading_localRÉ Râ ( ( ( s! /usr/lib64/python2.6/threading.pyt <module> s�
M u - & ÿ ) $ R