ó
|
M\¬Qc @ s d Z d d l Z y d d l Z Wn e k
|
rB e j e = n Xd d l Z d d l m Z
|
d d l m Z m Z d d l m Z d d d d d
|
d d d d d d d d d d d d g Z e j Z e j Z e j Z e j Z [ e j 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- Z/ d. e f d/ YZ0 d0 a1 d1 d2 Z2 e a3 i Z4 i Z5 d e f d3 YZ6 d4 Z7 d5 e6 f d6 YZ8 d7 e6 f d8 YZ9 d9 Z: d: e6 f d; YZ; d< Z< e< Z= d= Z> e> Z? d> Z@ d? ZA d d@ l mB ZB e9 jC ZD y d dA l mE ZF Wn! e k
|
ród dB lG mF ZF n XdC ZH dD ZI e dE k r eI n d S(F s; Thread module emulating a subset of Java's threading model.iÿÿÿÿN( t deque( t timet sleep( t
|
format_exct 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 k r t } n | | _ d S( N( t Nonet _VERBOSEt _Verbose__verbose( t selft verbose( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt __init__: s c G sr | j rn | | } t } y t | j } Wn t k
|
rJ d | } n Xd | | f } t j j | n d S( Ns <OS thread %d>s %s: %s
|
( R t
|
_get_identt _activet namet KeyErrort _syst stderrt write( R t formatt argst identR# ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt _note? s
|
N( t __name__t
|
__module__R R R+ ( ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR 8 s c C s
|
| a d S( s¸ Set a profile function for all threads started from the threading module.
|
|
The func will be passed to sys.setprofile() for each thread, before its
|
run() method is called.
|
|
N( t _profile_hook( t func( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR Y s c C s
|
| a d S( s´ Set a trace function for all threads started from the threading module.
|
|
The func will be passed to sys.settrace() for each thread, before its run()
|
method is called.
|
|
N( t _trace_hook( R/ ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR c s c O s t | | S( s2 Factory function that returns a new reentrant lock.
|
|
A reentrant lock must be released by the thread that acquired it. Once a
|
thread has acquired a reentrant lock, the same thread may acquire it again
|
without blocking; the thread must release it once for each time it has
|
acquired it.
|
|
( t _RLock( R) t kwargs( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR q s R1 c B sb e Z d Z d
|
d Z d Z d d Z e Z d Z d Z d Z
|
d Z d Z RS( s A reentrant lock must be released by the thread that acquired it. Once a
|
thread has acquired a reentrant lock, the same thread may acquire it
|
again without blocking; the thread must release it once for each time it
|
has acquired it.
|
c C s2 t j | | t | _ d | _ d | _ d S( Ni ( R R t _allocate_lockt _RLock__blockR t _RLock__ownert _RLock__count( R R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR s c C sH | j } y t | j } Wn t k
|
r- n Xd | j j | | j f S( Ns <%s owner=%r count=%d>( R5 R" R# R$ t __class__R, R6 ( R t owner( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt __repr__ s i c C s t } | j | k r? | j d | _ | j d | | d S| j j | } | r | | _ d | _ | j d | | n | j d | | | S( sî Acquire a lock, blocking or non-blocking.
|
|
When invoked without arguments: if this thread already owns the lock,
|
increment the recursion level by one, and return immediately. Otherwise,
|
if another thread owns the lock, block until the lock is unlocked. Once
|
the lock is unlocked (not owned by any thread), then grab ownership, set
|
the recursion level to one, and return. If more than one thread is
|
blocked waiting until the lock is unlocked, only one at a time will be
|
able to grab ownership of the lock. There is no return value in this
|
case.
|
|
When invoked with the blocking argument set to true, do the same thing
|
as when called without arguments, and return true.
|
|
When invoked with the blocking argument set to false, do not block. If a
|
call without an argument would block, return false immediately;
|
otherwise, do the same thing as when called without arguments, and
|
return true.
|
|
i s! %s.acquire(%s): recursive successs %s.acquire(%s): initial successs %s.acquire(%s): failure( R! R5 R6 R+ R4 t acquire( R t blockingt met rc( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR: s c C sx | j t k r! t d n | j d | _ } | sd d | _ | j j | j d | n | j d | d S( sm Release a lock, decrementing the recursion level.
|
|
If after the decrement it is zero, reset the lock to unlocked (not owned
|
by any thread), and if any other threads are blocked waiting for the
|
lock to become unlocked, allow exactly one of them to proceed. If after
|
the decrement the recursion level is still nonzero, the lock remains
|
locked and owned by the calling thread.
|
|
Only call this method when the calling thread owns the lock. A
|
RuntimeError is raised if this method is called when the lock is
|
unlocked.
|
|
There is no return value.
|
|
s cannot release un-acquired locki s %s.release(): final releases %s.release(): non-final releaseN( R5 R! t RuntimeErrorR6 R R4 t releaseR+ ( R t count( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR? º s c C s | j d S( N( R? ( R t tt vt tb( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt __exit__Ö s c C s? | \ } } | j j | | _ | | _ | j d | d S( Ns %s._acquire_restore()( R4 R: R6 R5 R+ ( R t count_ownerR@ R8 ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt _acquire_restoreÛ s
|
c C sK | j d | | j } d | _ | j } d | _ | j j | | f S( Ns %s._release_save()i ( R+ R6 R5 R R4 R? ( R R@ R8 ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt _release_saveã s c C s | j t k S( N( R5 R! ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt _is_ownedí s N( R, R- t __doc__R R R9 R: t __enter__R? RD RF RG RH ( ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR1 | s &
|
c O s t | | S( s} Factory function that returns a new condition variable object.
|
|
A condition variable allows one or more threads to wait until they are
|
notified by another thread.
|
|
If the lock argument is given and not None, it must be a Lock or RLock
|
object, and it is used as the underlying lock. Otherwise, a new RLock object
|
is created and used as the underlying lock.
|
|
( t
|
_Condition( R) R2 ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR ñ s RK c B sz e Z d 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( sl Condition variables allow one or more threads to wait until they are
|
notified by another thread.
|
c C s t j | | | d k r( t } n | | _ | j | _ | j | _ y | j | _ Wn t k
|
rl n Xy | j | _ Wn t k
|
r n Xy | j
|
| _
|
Wn t k
|
r´ n Xg | _ d S( N( R R R R t _Condition__lockR: R? RG t AttributeErrorRF RH t _Condition__waiters( R t lockR ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR s& c C s | j j S( N( RL RJ ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyRJ s c G s | j j | S( N( RL RD ( R R) ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyRD s c C s d | j t | j f S( Ns <Condition(%s, %d)>( RL t lenRN ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR9 " s c C s | j j d S( N( RL R? ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyRG % s c C s | j j d S( N( RL R: ( R t x( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyRF ( s c C s+ | j j d r# | j j t St Sd S( Ni ( RL R: R? t Falset True( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyRH + s c C sY | j s t d n t } | j | j j | | j } zú | d k rv | j | j d | nÍ t | } d } x` t
|
rë | j d } | r« Pn | t } | d k rÈ Pn t | d | d } t | q W| s0| j d | | y | j j | WqCt k
|
r,qCXn | j d | | Wd | j | Xd S(
|
sj Wait until notified or until a timeout occurs.
|
|
If the calling thread has not acquired the lock when this method is
|
called, a RuntimeError is raised.
|
|
This method releases the underlying lock, and then blocks until it is
|
awakened by a notify() or notifyAll() call for the same condition
|
variable in another thread, or until the optional timeout occurs. Once
|
awakened or timed out, it re-acquires the lock and returns.
|
|
When the timeout argument is present and not None, it should be a
|
floating point number specifying a timeout for the operation in seconds
|
(or fractions thereof).
|
|
When the underlying lock is an RLock, it is not released using its
|
release() method, since this may not actually unlock the lock when it
|
was acquired multiple times recursively. Instead, an internal interface
|
of the RLock class is used, which really unlocks it even when it has
|
been recursively acquired several times. Another internal interface is
|
then used to restore the recursion level when the lock is reacquired.
|
|
s cannot wait on un-acquired locks %s.wait(): got itgü©ñÒMb@?i i g©?s %s.wait(%s): timed outs %s.wait(%s): got itN( RH R> R3 R: RN t appendRG R R+ t _timeRS t mint _sleept removet
|
ValueErrorRF ( R t timeoutt waitert saved_statet endtimet delayt gotitt remaining( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt wait4 s:
|
|
i c C s´ | j s t d n | j } | | } | sH | j d | d S| j d | | | d k ri d pl d x= | D]5 } | j y | j | Wqw t k
|
r« qw Xqw Wd S( sK Wake up one or more threads waiting on this condition, if any.
|
|
If the calling thread has not acquired the lock when this method is
|
called, a RuntimeError is raised.
|
|
This method wakes up at most n of the threads waiting for the condition
|
variable; it is a no-op if no threads are waiting.
|
|
s! cannot notify on un-acquired locks %s.notify(): no waitersNs" %s.notify(): notifying %d waiter%si t st ( RH R> RN R+ R? RX RY ( R t nRN t waitersR[ ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt notifyt s
|
|
|
c C s | j t | j d S( s¯ Wake up all threads waiting on this condition.
|
|
If the calling thread has not acquired the lock when this method
|
is called, a RuntimeError is raised.
|
|
N( Rf RP RN ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt notifyAll s N( R, R- RI R R RJ RD R9 RG RF RH Ra Rf Rg t
|
notify_all( ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyRK þ s @ c O s t | | S( sO A factory function that returns a new semaphore.
|
|
Semaphores manage a counter representing the number of release() calls minus
|
the number of acquire() calls, plus an initial value. The acquire() method
|
blocks if necessary until it can return without making the counter
|
negative. If not given, value defaults to 1.
|
|
( t
|
_Semaphore( R) R2 ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR s Ri c B sA e Z d Z d d d Z d d Z e Z d Z d Z RS( s" Semaphores manage a counter representing the number of release() calls
|
minus the number of acquire() calls, plus an initial value. The acquire()
|
method blocks if necessary until it can return without making the counter
|
negative. If not given, value defaults to 1.
|
|
i c C sJ | d k r t d n t j | | t t | _ | | _ d S( Ni s$ semaphore initial value must be >= 0( RY R R R R t _Semaphore__condt _Semaphore__value( R t valueR ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR ° s
|
c C s t } | j w xo | j d k rU | s, Pn | j d | | | j | j j q W| j d | _ | j d | | j t } Wd QX| S( s Acquire a semaphore, decrementing the internal counter by one.
|
|
When invoked without arguments: if the internal counter is larger than
|
zero on entry, decrement it by one and return immediately. If it is zero
|
on entry, block, waiting until some other thread has called release() to
|
make it larger than zero. This is done with proper interlocking so that
|
if multiple acquire() calls are blocked, release() will wake exactly one
|
of them up. The implementation may pick one at random, so the order in
|
which blocked threads are awakened should not be relied on. There is no
|
return value in this case.
|
|
When invoked with blocking set to true, do the same thing as when called
|
without arguments, and return true.
|
|
When invoked with blocking set to false, do not block. If a call without
|
an argument would block, return false immediately; otherwise, do the
|
same thing as when called without arguments, and return true.
|
|
i s) %s.acquire(%s): blocked waiting, value=%si s %s.acquire: success, value=%sN( RR Rj Rk R+ Ra RS ( R R; R= ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR: · s
|
c C sG | j 8 | j d | _ | j d | | j | j j Wd QXd S( s× Release a semaphore, incrementing the internal counter by one.
|
|
When the counter is zero on entry and another thread is waiting for it
|
to become larger than zero again, wake up that thread.
|
|
i s %s.release: success, value=%sN( Rj Rk R+ Rf ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR? Þ s
|
|
c C s | j d S( N( R? ( R RA RB RC ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyRD ì s N( R, R- RI R R R: RJ R? RD ( ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyRi ¦ s % c O s t | | S( s A factory function that returns a new bounded semaphore.
|
|
A bounded semaphore checks to make sure its current value doesn't exceed its
|
initial value. If it does, ValueError is raised. In most situations
|
semaphores are used to guard resources with limited capacity.
|
|
If the semaphore is released too many times it's a sign of a bug. If not
|
given, value defaults to 1.
|
|
Like regular semaphores, bounded semaphores manage a counter representing
|
the number of release() calls minus the number of acquire() calls, plus an
|
initial value. The acquire() method blocks if necessary until it can return
|
without making the counter negative. If not given, value defaults to 1.
|
|
( t _BoundedSemaphore( R) R2 ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR ð s Rm c B s& e Z d Z d d d Z d Z RS( sá A bounded semaphore checks to make sure its current value doesn't exceed
|
its initial value. If it does, ValueError is raised. In most situations
|
semaphores are used to guard resources with limited capacity.
|
i c C s t j | | | | | _ d S( N( Ri R t _initial_value( R Rl R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR s c C s. | j | j k r! t d n t j | S( s6 Release a semaphore, incrementing the internal counter by one.
|
|
When the counter is zero on entry and another thread is waiting for it
|
to become larger than zero again, wake up that thread.
|
|
If the number of releases exceeds the number of acquires,
|
raise a ValueError.
|
|
s! Semaphore released too many times( Rk Rn RY Ri R? ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR? s
|
N( R, R- RI R R R? ( ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyRm s c O s t | | S( sß A factory function that returns a new event.
|
|
Events manage a flag that can be set to true with the set() method and reset
|
to false with the clear() method. The wait() method blocks until the flag is
|
true.
|
|
( t _Event( R) R2 ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR
|
s Ro c B sP e Z d Z d d Z d Z d Z e Z d Z d Z d d Z
|
RS( sê A factory function that returns a new event object. An event manages a
|
flag that can be set to true with the set() method and reset to false
|
with the clear() method. The wait() method blocks until the flag is true.
|
|
c C s/ t j | | t t | _ t | _ d S( N( R R R R t _Event__condRR t _Event__flag( R R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR . s c C s | j j d S( N( Rp R ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt _reset_internal_locks3 s c C s | j S( s5 Return true if and only if the internal flag is true.( Rq ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt isSet7 s c C s< | j j z t | _ | j j Wd | j j Xd S( s½ Set the internal flag to true.
|
|
All threads waiting for the flag to become true are awakened. Threads
|
that call wait() once the flag is true will not block at all.
|
|
N( Rp R: RS Rq Rh R? ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt set= s
|
c C s/ | j j z t | _ Wd | j j Xd S( sª Reset the internal flag to false.
|
|
Subsequently, threads calling wait() will block until set() is called to
|
set the internal flag to true again.
|
|
N( Rp R: RR Rq R? ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt clearK s c C sI | j j z' | j s, | j j | n | j SWd | j j Xd S( sH Block until the internal flag is true.
|
|
If the internal flag is true on entry, return immediately. Otherwise,
|
block until another thread calls set() to set the flag to true, or until
|
the optional timeout occurs.
|
|
When the timeout argument is present and not None, it should be a
|
floating point number specifying a timeout for the operation in seconds
|
(or fractions thereof).
|
|
This method returns the internal flag on exit, so it will always return
|
True except if a timeout is given and the operation times out.
|
|
N( Rp R: Rq Ra R? ( R RZ ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyRa X s N( R, R- RI R R Rr Rs t is_setRt Ru Ra ( ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyRo % s i s Thread-%dc C s t d a | t S( Ni ( t _counter( t template( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt _newnameq s
|
c B s: e Z d Z e Z e j Z e j Z d d d d d d d Z d Z e 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 j d Z e d Z d Z e Z e d Z e j d Z d Z d Z d Z! d Z" RS( sq A class that represents a thread of control.
|
|
This class can be safely subclassed in a limited fashion.
|
|
c C sÈ | d k s t d t j | | | d k r= i } n | | _ t | pU t | _ | | _ | | _ | j
|
| _ d | _ t | _ t | _ t t | _ t | _ t j | _ d S( sC This constructor should always be called with keyword arguments. Arguments are:
|
|
*group* should be None; reserved for future extension when a ThreadGroup
|
class is implemented.
|
|
*target* is the callable object to be invoked by the run()
|
method. Defaults to None, meaning nothing is called.
|
|
*name* is the thread name. By default, a unique name is constructed of
|
the form "Thread-N" where N is a small decimal number.
|
|
*args* is the argument tuple for the target invocation. Defaults to ().
|
|
*kwargs* is a dictionary of keyword arguments for the target
|
invocation. Defaults to {}.
|
|
If a subclass overrides the constructor, it must make sure to invoke
|
the base class constructor (Thread.__init__()) before doing anything
|
else to the thread.
|
|
s# group argument must be None for nowN( R t AssertionErrorR R t _Thread__targett strRy t _Thread__namet _Thread__argst _Thread__kwargst _set_daemont _Thread__daemonict _Thread__identR
|
t _Thread__startedRR t _Thread__stoppedR R t _Thread__blockRS t _Thread__initializedR% R& t _Thread__stderr( R t groupt targetR# R) R2 R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR s c C s0 t | d r | j j n | j j d S( NR
( t hasattrR
R R Rr ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyRr · s c C s | j S( N( R
( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt _block¾ s c C s
|
t j S( N( R t daemon( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR Ã s c C s | j s t d d } | j j r3 d } n | j rE d } n | j r[ | d 7} n | j d k r~ | d | j 7} n d | j j | j
|
| f S( Ns Thread.__init__() was not calledt initialt startedt stoppeds daemons %ss <%s(%s, %s)>( R Rz R Rv R R R R R7 R, R} ( R t status( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR9 Ç s c C s | j s t d n | j j r6 t d n | j d | t | t | <Wd QXy t | j d Wn( t k
|
r t t | =Wd QX n X| j j
|
d S( s- Start the thread's activity.
|
|
It must be called at most once per thread object. It arranges for the
|
object's run() method to be invoked in a separate thread of control.
|
|
This method will raise a RuntimeError if called more than once on the
|
same thread object.
|
|
s thread.__init__() not calleds threads can only be started onces %s.start(): starting threadN( ( R R> R Rv R+ t _active_limbo_lockt _limbot _start_new_threadt _Thread__bootstrapt ExceptionRa ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt startÔ s
|
c C s@ z& | j r% | j | j | j n Wd | ` | ` | ` Xd S( sX Method representing the thread's activity.
|
|
You may override this method in a subclass. The standard run() method
|
invokes the callable object passed to the object's constructor as the
|
target argument, if any, with sequential and keyword arguments taken
|
from the args and kwargs arguments, respectively.
|
|
N( R{ R~ R ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt runî s c C s8 y | j Wn# | j r- t d k r- d S n Xd S( N( t _Thread__bootstrap_innerR R% R ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt __bootstrapÿ s c C s t | _ d S( N( R! R ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt
|
_set_ident s c
|
C s zÒ| j | j j t | t | j <t | =Wd QX| j d | t rq | j d | t j
|
t n t r | j d | t j t n z,y | j Wnt k
|
rË | j d | n÷ | j d | t rt j j d | j t f qÂ| j \ } } } z
| j d | j d IJ| j d IJxB | r| j d
|
| j j j | j | j j j f IJ| j } qGW| j d | | f IJWd ~ ~ ~ Xn X| j d | Wd | j XWd t ' | j y t t =Wn n XWd QXXd S( Ns %s.__bootstrap(): thread starteds( %s.__bootstrap(): registering trace hooks* %s.__bootstrap(): registering profile hooks# %s.__bootstrap(): raised SystemExits% %s.__bootstrap(): unhandled exceptions 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: %ss %s.__bootstrap(): normal return( R R Rt R R" R R R+ R0 R% R R. R R t
|
SystemExitR& R' R# t _format_exct _Thread__exc_infoR t tb_framet f_codet co_filenamet tb_linenot co_namet tb_nextt _Thread__exc_cleart _Thread__stopR! ( R t exc_typet exc_valuet exc_tb( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt __bootstrap_inner s^
|
|
|
c C sG t | d s d S| j j t | _ | j j | j j d S( NR
( R R
R: RS R Rh R? ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt __stop` s c C sH y t t t =Wd QXWn& t k
|
rC d t j k rD qD n Xd S( sA Remove current thread from the dict of currently running threads.Nt dummy_threading( R R" R! R$ R% t modules( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt __deletej s c C s< | j s t d n | j j s6 t d n | t k rT t d n | j sp | j d | n | j j zª | d k r¼ x | j s¨ | j j
|
q W| j d | nj t | } xZ | j s| t } | d k r| j d | Pn | j j
|
| qÌ W| j d | Wd | j j Xd S( s Wait until the thread terminates.
|
|
This blocks the calling thread until the thread whose join() method is
|
called terminates -- either normally or through an unhandled exception
|
or until the optional timeout occurs.
|
|
When the timeout argument is present and not None, it should be a
|
floating point number specifying a timeout for the operation in seconds
|
(or fractions thereof). As join() always returns None, you must call
|
isAlive() after join() to decide whether a timeout happened -- if the
|
thread is still alive, the join() call timed out.
|
|
When the timeout argument is not present or None, the operation will
|
block until the thread terminates.
|
|
A thread can be join()ed many times.
|
|
join() raises a RuntimeError if an attempt is made to join the current
|
thread as that would cause a deadlock. It is also an error to join() a
|
thread before it has been started and attempts to do so raises the same
|
exception.
|
|
s Thread.__init__() not calleds' cannot join thread before it is starteds cannot join current threads% %s.join(): waiting until thread stopss %s.join(): thread stoppedi s %s.join(): timed outN( R R> R Rv R R R+ R
R: R Ra RU R? ( R RZ t deadlineR^ ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt join s. c C s | j s t d | j S( s¸ A string used for identification purposes only.
|
|
It has no semantics. Multiple threads may be given the same name. The
|
initial name is set by the constructor.
|
|
s Thread.__init__() not called( R Rz R} ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR# Å s c C s( | j s t d t | | _ d S( Ns Thread.__init__() not called( R Rz R| R} ( R R# ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR# Ð s c C s | j s t d | j S( s; Thread identifier of this thread or None if it has not been started.
|
|
This is a nonzero integer. See the thread.get_ident() function. Thread
|
identifiers may be recycled when a thread exits and another thread is
|
created. The identifier is available even after the thread has exited.
|
|
s Thread.__init__() not called( R Rz R ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR* Õ s c C s, | j s t d | j j o+ | j S( sö Return whether the thread is alive.
|
|
This method returns True just before the run() method starts until just
|
after the run() method terminates. The module function enumerate()
|
returns a list of all alive threads.
|
|
s Thread.__init__() not called( R Rz R Rv R ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt isAliveá s c C s | j s t d | j S( sÜ A boolean value indicating whether this thread is a daemon thread (True) or not (False).
|
|
This must be set before start() is called, otherwise RuntimeError is
|
raised. Its initial value is inherited from the creating thread; the
|
main thread is not a daemon thread and therefore all threads created in
|
the main thread default to daemon = False.
|
|
The entire Python program exits when no alive non-daemon threads are
|
left.
|
|
s Thread.__init__() not called( R Rz R ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR î s c C sC | j s t d n | j j r6 t d n | | _ d S( Ns Thread.__init__() not calleds) cannot set daemon status of active thread( R R> R Rv R ( R t daemonic( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR þ s
|
c C s | j S( N( R ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt isDaemon s c C s | | _ d S( N( R ( R R± ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt setDaemon s c C s | j S( N( R# ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt getName s c C s | | _ d S( N( R# ( R R# ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt setName s N( (# R, R- RI RR R R% t exc_infoR t exc_clearR¤ R R Rr t propertyR R R9 R R R R R R¥ t _Thread__deleteR¯ R# t setterR* R° t is_aliveR R² R³ R´ Rµ ( ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR ~ s: ( J
|
# 8 c O s t | | S( sú Factory function to create a Timer object.
|
|
Timers 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
|
|
( t _Timer( R) R2 ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR s
|
R¼ c B s/ e Z d Z g i 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 j | | | _ | | _ | | _ | | _ t | _ d S( N( R R t intervalt functionR) R2 R
|
t finished( R R½ R¾ R) R2 ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR ) s c C s | j j d S( s( Stop the timer if it hasn't finished yetN( R¿ Rt ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt cancel1 s c C sL | j j | j | j j s; | j | j | j n | j j d S( N( R¿ Ra R½ Rv R¾ R) R2 Rt ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR 5 s ( R, R- RI R RÀ R ( ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR¼ s t _MainThreadc B s# e Z d Z d Z d Z RS( c C sH t j | d d | j j | j t | t t <Wd QXd S( NR# t
|
MainThread( R R R Rt R R R" R! ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR @ s
|
|
c C s t S( N( RR ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR G s c C sj | j t } | r, | j d | n x | rK | j t } q/ W| j d | | j d S( Ns %s: waiting for other threadss %s: exiting( R¥ t _pickSomeNonDaemonThreadR+ R¯ R¹ ( R RA ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt _exitfuncJ s
|
|
( R, R- R R RÄ ( ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyRÁ > s c C s2 x+ t D] } | j r
|
| j r
|
| Sq
|
Wd S( N( R R R» R ( RA ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyRÃ W s t _DummyThreadc B s& e Z d Z d Z d d Z RS( c C sT t j | d t d | ` | j j | j t | t t <Wd QXd S( NR# s Dummy-%d(
|
R R Ry R
R Rt R R R" R! ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR h s
|
c C s t S( N( RS ( R ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR u s c C s t s t d d S( Ns cannot join a dummy thread( RR Rz ( R RZ ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR¯ x s N( R, R- R R R R¯ ( ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyRÅ f s c C s+ y t t SWn t k
|
r& t SXd S( sï Return the current Thread object, corresponding to the caller's thread of control.
|
|
If the caller's thread of control was not created through the threading
|
module, a dummy thread object with limited functionality is returned.
|
|
N( R" R! R$ RÅ ( ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR ~ s c C s% t t t t t SWd QXd S( s Return the number of Thread objects currently alive.
|
|
The returned count is equal to the length of the list returned by
|
enumerate().
|
|
N( R RP R" R ( ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR s c C s t j t j S( N( R" t valuesR ( ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt
|
_enumerate s c C s% t t j t j SWd QXd S( sý Return a list of all Thread objects currently alive.
|
|
The list includes daemonic threads, dummy thread objects created by
|
current_thread(), and the main thread. It excludes terminated threads and
|
threads that have not yet been started.
|
|
N( R R" RÆ R ( ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR s ( R ( t _local( R c C sÊ t a i } t } t ¦ xe t j D]W } t | d rN | j n | | k ry t } | | _ | | | <q, | j q, Wt
|
j t j t j | t t d k sÀ t Wd QXd S( NRr i ( R3 R R R" t
|
itervaluesR Rr R! R R¥ R Ru t updateRP Rz ( t
|
new_activet currentt threadR* ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt _after_fork¹ 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 | _ | j | qs W| | | | }
|
x" | D] } | j t d qÄ W|
|
j x | D] } | j qó W|
|
j d S( Nt BoundedQueuec B s# e Z d Z d Z d Z RS( c S sV t j | t | _ t | j | _ t | j | _ | | _ t | _ d S( N(
|
R R R t monR R= t wct limitt _dequet queue( R RÒ ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR â s c S s | j j x9 t | j | j k rH | j d | | j j q W| j j | | j d | t | j | j j
|
| j j d S( Ns put(%s): queue fulls put(%s): appended, length now %d( RÐ R: RP RÔ RÒ R+ RÑ Ra RT R= Rf R? ( R t item( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt putê s c S s | j j x' | j s6 | j d | j j q W| j j } | j d | t | j | j j | j j
|
| S( Ns get(): queue emptys get(): got %s, %d left( RÐ R: RÔ R+ R= Ra t popleftRP RÑ Rf R? ( R RÕ ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt getõ s ( R, R- R RÖ RØ ( ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyRÏ à s t ProducerThreadc B s e Z d Z d Z RS( c S s) t j | d d | | _ | | _ d S( NR# t Producer( R R RÔ t quota( R RÔ RÛ ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR s c S sh d d l m } d } xK | | j k rc | d } | j j d | j | f t | d q Wd S( Niÿÿÿÿ( t randomi i s %s.%dgñhãµøä>( RÜ RÛ RÔ RÖ R# RW ( R RÜ t counter( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR s
|
( R, R- R R ( ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyRÙ s t ConsumerThreadc B s e Z d Z d Z RS( c S s) t j | d d | | _ | | _ d S( NR# t Consumer( R R RÔ R@ ( R RÔ R@ ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR s c S s> x7 | j d k r9 | j j } | GH| j d | _ q Wd S( Ni i ( R@ RÔ RØ ( R RÕ ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyR s ( R, R- R R ( ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyRÞ s i i i s Producer-%di gíµ ÷Æ°>( R R t rangeR# RT R RW R¯ ( RÏ RÙ RÞ t NPt QLt NIt Qt Pt iRA t C( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt _testÞ s(
|
|
t __main__(J RI t sysR% RÍ t ImportErrorR¬ R, t warningst collectionsR RÓ R RU R RW t tracebackR R t __all__t start_new_threadR t allocate_lockR3 t get_identR! t errort ThreadErrort filterwarningst DeprecationWarningRR R t objectR R R. R0 R R R R R1 R RK R Ri R Rm R
|
Ro Rw Ry R R" R R R R¼ RÁ RÃ RÅ R R R R RÇ R R RÄ t _shutdownRÈ R t _threading_localRÎ Rè ( ( ( sQ /tmp/ndk-User/buildhost/install/prebuilt/darwin-x86_64/lib/python2.7/threading.pyt <module> s
|
|
u J
|
K ÿ
|
% R
|
