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.iN( 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 ( 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 lockgMb@?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 | 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 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 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.%dgh㈵>( 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 s
M u - & ) $ R