Submit
Path:
~
/
/
proc
/
thread-self
/
root
/
opt
/
alt
/
python34
/
lib64
/
python3.4
/
__pycache__
/
File Content:
threading.cpython-34.pyo
� � f�� � # @ s~ d Z d d l Z d d l Z y d d l m Z Wn" e k rV d d l m Z Yn Xd d l m Z d d l m Z d d l m Z m Z y d d l m Z Wn" e k r� d d l m Z Yn Xd 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 Z y e j Z Wn e! k rSd Z Yn Xe j" Z" [ d a# d a$ d d � Z% d d � Z& e Z' d d � Z Gd d � d � Z( e( Z) Gd d � d � Z* Gd d � d � Z+ Gd! d � d e+ � Z, Gd" d � d � Z- Gd# d � d � Z. Gd$ d% � d% e/ � Z0 e � j1 Z2 e2 � d& d' d( � Z3 e � a4 i Z5 i Z6 e � Z7 Gd) d � d � Z8 Gd* d � d e8 � Z9 Gd+ d, � d, e8 � Z: Gd- d. � d. e8 � Z; d/ d � Z< e< Z= d0 d � Z> e> Z? d1 d2 � Z@ d3 d � ZA d d4 l mB ZB e: � aC d5 d6 � ZD d7 d8 � ZE d9 d: � ZF y d d; l mG ZH Wn" e k rmd d< lI mH ZH Yn Xd= d> � ZJ d S)?z;Thread module emulating a subset of Java's threading model.� N)� monotonic)�time)� format_exc)�WeakSet)�islice�count)�deque� active_count� Condition�current_thread� enumerate�Event�Lock�RLock� Semaphore�BoundedSemaphore�Thread�Barrier�Timer� ThreadError� setprofile�settrace�local� stack_sizec C s | a d S)z�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)� _profile_hook)�func� r �./opt/alt/python34/lib64/python3.4/threading.pyr 3 s c C s | a d S)z�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)� _trace_hook)r r r r r = s c O s& t d k r t | | � St | | � S)a2 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. N)�_CRLock�_PyRLock)�args�kwargsr r r r K s c @ s� e Z d Z d Z d d � Z d d � Z d d d d � Z e Z d d � Z d d � Z d d � Z d d � Z d d � Z d S)�_RLocka, This class implements reentrant lock objects. 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 s" t � | _ d | _ d | _ d S)Nr )�_allocate_lock�_block�_owner�_count)�selfr r r �__init__b s z_RLock.__init__c C sI | j } y t | j } Wn t k r. Yn Xd | j j | | j f S)Nz<%s owner=%r count=%d>)r& �_active�name�KeyError� __class__�__name__r' )r( �ownerr r r �__repr__g s z_RLock.__repr__T� c C s_ t � } | j | k r+ | j d 7_ d S| j j | | � } | r[ | | _ d | _ n | S)a 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. When invoked with the floating-point timeout argument set to a positive value, block for at most the number of seconds specified by timeout and as long as the lock cannot be acquired. Return true if the lock has been acquired, false if the timeout has elapsed. r1 )� get_identr& r' r% �acquire)r( �blocking�timeout�me�rcr r r r3 p s z_RLock.acquirec C sX | j t � k r! t d � � n | j d | _ } | sT d | _ | j j � n d S)am 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. z cannot release un-acquired lockr1 N)r& r2 � RuntimeErrorr' r% �release)r( r r r r r9 � s z_RLock.releasec C s | j � d S)N)r9 )r( �t�v�tbr r r �__exit__� s z_RLock.__exit__c C s# | j j � | \ | _ | _ d S)N)r% r3 r' r& )r( �stater r r �_acquire_restore� s z_RLock._acquire_restorec C sY | j d k r t d � � n | j } d | _ | j } d | _ | j j � | | f S)Nr z cannot release un-acquired lock)r' r8 r& r% r9 )r( r r/ r r r � _release_save� s z_RLock._release_savec C s | j t � k S)N)r& r2 )r( r r r � _is_owned� s z_RLock._is_ownedN���) r. � __module__� __qualname__�__doc__r) r0 r3 � __enter__r9 r= r? r@ rA r r r r r# X s $ r# c @ s� e Z d Z d Z d d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d d � Z d d d � Z d d d � Z d d � Z e Z d S)r aj Class that implements a condition variable. 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. Nc C s� | d k r t � } n | | _ | j | _ | j | _ y | j | _ Wn t k r] Yn Xy | j | _ Wn t k r� Yn Xy | j | _ Wn t k r� Yn Xt � | _ d S)N) r �_lockr3 r9 r@ �AttributeErrorr? rA �_deque�_waiters)r( �lockr r r r) � s$ zCondition.__init__c C s | j j � S)N)rG rF )r( r r r rF � s zCondition.__enter__c G s | j j | � S)N)rG r= )r( r! r r r r= � s zCondition.__exit__c C s d | j t | j � f S)Nz<Condition(%s, %d)>)rG �lenrJ )r( r r r r0 � s zCondition.__repr__c C s | j j � d S)N)rG r9 )r( r r r r@ � s zCondition._release_savec C s | j j � d S)N)rG r3 )r( �xr r r r? � s zCondition._acquire_restorec C s+ | j j d � r# | j j � d Sd Sd S)Nr FT)rG r3 r9 )r( r r r rA � s zCondition._is_ownedc C s� | j � s t d � � n t � } | j � | j j | � | j � } d } zW | d k rr | j � d } n0 | d k r� | j d | � } n | j d � } | SWd | j | � | s� y | j j | � Wq� t k r� Yq� Xn Xd S)ak 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 notify_all() 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. z cannot wait on un-acquired lockFNTr ) rA r8 r$ r3 rJ �appendr@ r? �remove� ValueError)r( r5 �waiterZ saved_stateZgotitr r r �wait s* zCondition.waitc C s� d } | } | � } xh | s | d k rf | d k rF t � | } qf | t � } | d k rf Pqf n | j | � | � } q W| S)z�Wait until a condition evaluates to True. predicate should be a callable which result will be interpreted as a boolean value. A timeout may be provided giving the maximum time to wait. Nr )�_timerR )r( Z predicater5 �endtimeZwaittime�resultr r r �wait_for2 s zCondition.wait_forr1 c C s� | j � s t d � � n | j } t t | | � � } | sC d Sx> | D]6 } | j � y | j | � WqJ t k r YqJ XqJ Wd S)aK 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. z!cannot notify on un-acquired lockN)rA r8 rJ rI �_islicer9 rO rP )r( �nZ all_waitersZwaiters_to_notifyrQ r r r �notifyI s zCondition.notifyc C s | j t | j � � d S)z�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)rY rL rJ )r( r r r � notify_all` s zCondition.notify_all)r. rC rD rE r) rF r= r0 r@ r? rA rR rV rY rZ Z notifyAllr r r r r � s 0 c @ sU e Z d Z d Z d d d � Z d d d d � Z e Z d d � Z d d � Z d S) r aG This class implements semaphore objects. 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. r1 c C s: | d k r t d � � n t t � � | _ | | _ d S)Nr z$semaphore initial value must be >= 0)rP r r �_cond�_value)r( �valuer r r r) x s zSemaphore.__init__TNc C s� | r" | d k r" t d � � n d } d } | j �� x� | j d k r� | sT Pn | d k r� | d k r| t � | } q� | t � } | d k r� Pq� n | j j | � q; W| j d 8_ d } Wd QX| S)a� 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. When invoked with a timeout other than None, it will block for at most timeout seconds. If acquire does not complete successfully in that interval, return false. Return true otherwise. Nz.can't specify timeout for non-blocking acquireFr r1 T)rP r[ r\ rS rR )r( r4 r5 r7 rT r r r r3 ~ s$ zSemaphore.acquirec C s0 | j �! | j d 7_ | j j � Wd QXd S)z�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. r1 N)r[ r\ rY )r( r r r r9 � s zSemaphore.releasec C s | j � d S)N)r9 )r( r: r; r< r r r r= � s zSemaphore.__exit__) r. rC rD rE r) r3 rF r9 r= r r r r r l s - c @ s1 e Z d Z d Z d d d � Z d d � Z d S)r a� Implements a 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. r1 c C s t j | | � | | _ d S)N)r r) �_initial_value)r( r] r r r r) � s zBoundedSemaphore.__init__c C sQ | j �B | j | j k r+ t d � � n | j d 7_ | j j � Wd QXd S)a6 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. z!Semaphore released too many timesr1 N)r[ r\ r^ rP rY )r( r r r r9 � s zBoundedSemaphore.releaseN)r. rC rD rE r) r9 r r r r r � s c @ sg e Z d Z d Z d d � Z d d � Z d d � Z e Z d d � Z d d � Z d d d � Z d S)r z�Class implementing event objects. 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. The flag is initially false. c C s t t � � | _ d | _ d S)NF)r r r[ �_flag)r( r r r r) � s zEvent.__init__c C s | j j t � � d S)N)r[ r) r )r( r r r �_reset_internal_locks� s zEvent._reset_internal_locksc C s | j S)z5Return true if and only if the internal flag is true.)r_ )r( r r r �is_set� s z Event.is_setc C s* | j � d | _ | j j � Wd QXd S)z�Set the internal flag to true. All threads waiting for it to become true are awakened. Threads that call wait() once the flag is true will not block at all. TN)r[ r_ rZ )r( r r r �set� s z Event.setc C s | j � d | _ Wd QXd S)z�Reset the internal flag to false. Subsequently, threads calling wait() will block until set() is called to set the internal flag to true again. FN)r[ r_ )r( r r r �clear s z Event.clearNc C s< | j �- | j } | s. | j j | � } n | SWd QXd S)aH 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)r[ r_ rR )r( r5 Zsignaledr r r rR s z Event.wait) r. rC rD rE r) r` ra ZisSetrb rc rR r r r r r � s c @ s� e Z d Z d Z d d d d � Z d d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z e d d � � Z e d d � � Z e d d � � Z d S)r z�Implements a Barrier. Useful for synchronizing a fixed number of threads at known synchronization points. Threads block on 'wait()' and are simultaneously once they have all made that call. Nc C sC t t � � | _ | | _ | | _ | | _ d | _ d | _ d S)aW Create a barrier, initialised to 'parties' threads. 'action' is a callable which, when supplied, will be called by one of the threads after they have all entered the barrier and just prior to releasing them all. If a 'timeout' is provided, it is uses as the default for all subsequent 'wait()' calls. r N)r r r[ �_action�_timeout�_parties�_stater' )r( �parties�actionr5 r r r r) : s zBarrier.__init__c C s� | d k r | j } n | j �y | j � | j } | j d 7_ z5 | d | j k rg | j � n | j | � | SWd | j d 8_ | j � XWd QXd S)aN Wait for the barrier. When the specified number of threads have started waiting, they are all simultaneously awoken. If an 'action' was provided for the barrier, one of the threads will have executed that callback prior to returning. Returns an individual index number from 0 to 'parties-1'. Nr1 )re r[ �_enterr' rf �_release�_wait�_exit)r( r5 �indexr r r rR J s z Barrier.waitc C s? x | j d k r" | j j � q W| j d k r; t � n d S)Nr1 r rB )rB r1 )rg r[ rR �BrokenBarrierError)r( r r r rj h s zBarrier._enterc C sL y0 | j r | j � n d | _ | j j � Wn | j � � Yn Xd S)Nr1 )rd rg r[ rZ �_break)r( r r r rk s s zBarrier._releasec sP � j j � f d d � | � s4 � j � t � n � j d k rL t � n d S)Nc s � j d k S)Nr )rg r )r( r r �<lambda>� s z Barrier._wait.<locals>.<lambda>r )r[ rV rp ro rg )r( r5 r )r( r rl � s ! z Barrier._waitc C s> | j d k r: | j d k r: d | _ | j j � q: n d S)Nr r1 rB )rB r1 )r' rg r[ rZ )r( r r r rm � s z Barrier._exitc C sr | j �c | j d k rR | j d k r4 d | _ q[ | j d k r[ d | _ q[ n d | _ | j j � Wd QXd S)z�Reset the barrier to the initial state. Any threads currently waiting will get the BrokenBarrier exception raised. r r1 � NrB ���rB )r[ r' rg rZ )r( r r r �reset� s z Barrier.resetc C s | j � | j � Wd QXd S)z�Place the barrier into a 'broken' state. Useful in case of error. Any currently waiting threads and threads attempting to 'wait()' will have BrokenBarrierError raised. N)r[ rp )r( r r r �abort� s z Barrier.abortc C s d | _ | j j � d S)Nrr rs )rg r[ rZ )r( r r r rp � s zBarrier._breakc C s | j S)z:Return the number of threads required to trip the barrier.)rf )r( r r r rh � s zBarrier.partiesc C s | j d k r | j Sd S)z>Return the number of threads currently waiting at the barrier.r )rg r' )r( r r r � n_waiting� s zBarrier.n_waitingc C s | j d k S)z0Return True if the barrier is in a broken state.rr rs )rg )r( r r r �broken� s zBarrier.broken)r. rC rD rE r) rR rj rk rl rm rt ru rp �propertyrh rv rw r r r r r 1 s c @ s e Z d Z d S)ro N)r. rC rD r r r r ro � s ro z Thread-%dc C s | t � S)N)�_counter)�templater r r �_newname� s r{ c @ s� e Z d Z d Z d Z e j Z d d d f d d d d d �Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d d � Z d d3 d d � Z e d! d" � � Z e j d# d" � � Z e d$ d% � � Z d& d' � Z e Z e d( d) � � Z e j d* d) � � Z d+ d, � Z d- d. � Z d/ d0 � Z d1 d2 � Z d S)4r a A class that represents a thread of control. This class can be safely subclassed in a limited fashion. There are two ways to specify the activity: by passing a callable object to the constructor, or by overriding the run() method in a subclass. FN�daemonc C s� | d k r i } n | | _ t | p- t � � | _ | | _ | | _ | d k r` | | _ n t � j | _ d | _ d | _ t � | _ d | _ d | _ t j | _ t j | � d S)aK 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. NFT)�_target�strr{ �_name�_args�_kwargs� _daemonicr r| �_ident� _tstate_lockr �_started� _is_stopped� _initialized�_sys�stderr�_stderr� _dangling�add)r( �group�targetr+ r! r" r| r r r r) � s zThread.__init__c C s6 | j j � | r | j � n d | _ d | _ d S)NT)r� r` �_set_tstate_lockr� r� )r( �is_aliver r r r` s z Thread._reset_internal_locksc C s� d } | j j � r d } n | j � | j r: d } n | j rP | d 7} n | j d k rs | d | j 7} n d | j j | j | f S)N�initialZstartedZstoppedz daemonz %sz <%s(%s, %s)>) r� ra r� r� r� r� r- r. r )r( Zstatusr r r r0 ) s zThread.__repr__c C s� | j s t d � � n | j j � r6 t d � � n t � | t | <Wd QXy t | j f � Wn) t k r� t � t | =Wd QX� Yn X| j j � d S)a- 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. z thread.__init__() not calledz threads can only be started onceN) r� r8 r� ra �_active_limbo_lock�_limbo�_start_new_thread� _bootstrap� ExceptionrR )r( r r r �start7 s z Thread.startc C s@ z& | j r% | j | j | j � n Wd | ` | ` | ` Xd S)aX 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( r r r �runP s z Thread.runc C s9 y | j � Wn$ | j r- t d k r- d S� Yn Xd S)N)�_bootstrap_innerr� r� )r( r r r r� a s zThread._bootstrapc C s t � | _ d S)N)r2 r� )r( r r r � _set_identu s zThread._set_identc C s t � | _ | j j � d S)z� Set a lock object which will be released by the interpreter when the underlying thread state (see pystate.h) gets deleted. N)� _set_sentinelr� r3 )r( r r r r� x s zThread._set_tstate_lockc 1 C s� z�| j � | j � | j j � t � | t | j <t | =Wd QXt r[ t j t � n t rq t j t � n z:y | j � Wn%t k r� Ynt r� t j d k r� t d | j t � f d | j �n� | j d k r�| j � \ } } } z� t d | j d d | j �t d d | j �xH | rvt d | j j j | j | j j j f d | j �| j } q/Wt d | | f d | j �Wd ~ ~ ~ Xn Yn XWd XWd t � y t t � =Wn Yn XWd QXXd S)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� rb r� r* r� r� r r� r r r r� � SystemExitr� �printr+ � _format_excr� � _exc_info�tb_frame�f_code� co_filename� tb_lineno�co_name�tb_nextr2 )r( �exc_type� exc_valueZexc_tbr r r r� � sT !zThread._bootstrap_innerc C s. | j } | d k r n d | _ d | _ d S)NT)r� r� )r( rK r r r �_stop� s z Thread._stopc C sI y t � t t � =Wd QXWn' t k rD d t j k r@ � n Yn Xd S)zARemove current thread from the dict of currently running threads.NZdummy_threading)r� r* r2 r, r� �modules)r( r r r �_delete� s zThread._deletec C s� | j s t d � � n | j j � s6 t d � � n | t � k rT t d � � n | d k rm | j � n | j d t | d � � d S)a 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. z Thread.__init__() not calledz'cannot join thread before it is startedzcannot join current threadNr5 r )r� r8 r� ra r �_wait_for_tstate_lock�max)r( r5 r r r �join� s z Thread.joinTr1 c C sE | j } | d k r n) | j | | � rA | j � | j � n d S)N)r� r3 r9 r� )r( �blockr5 rK r r r r� ! s z Thread._wait_for_tstate_lockc C s | j S)z�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. )r )r( r r r r+ / s z Thread.namec C s t | � | _ d S)N)r~ r )r( r+ r r r r+ : s c C s | j S)a; 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. )r� )r( r r r �ident? s z Thread.identc C s2 | j s | j j � r d S| j d � | j S)z�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. F)r� r� ra r� )r( r r r r� K s zThread.is_alivec C s | j S)a� A boolean value indicating whether this thread is a daemon thread. 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. )r� )r( r r r r| [ s z Thread.daemonc C sC | j s t d � � n | j j � r6 t d � � n | | _ d S)Nz Thread.__init__() not calledz)cannot set daemon status of active thread)r� r8 r� ra r� )r( �daemonicr r r r| k s c C s | j S)N)r| )r( r r r �isDaemons s zThread.isDaemonc C s | | _ d S)N)r| )r( r� r r r � setDaemonv s zThread.setDaemonc C s | j S)N)r+ )r( r r r �getNamey s zThread.getNamec C s | | _ d S)N)r+ )r( r+ r r r �setName| s zThread.setNamerB ) r. rC rD rE r� r� �exc_infor� r) r` r0 r� r� r� r� r� r� r� r� r� r� rx r+ �setterr� r� ZisAliver| r� r� r� r� r r r r r � s8 , A #& c @ s@ e Z d Z d Z d d d d � Z d d � Z d d � Z d S) r z�Call a function after a specified number of seconds: t = Timer(30.0, f, args=None, kwargs=None) t.start() t.cancel() # stop the timer's action if it's still waiting Nc C se t j | � | | _ | | _ | d k r1 | n g | _ | d k rL | n i | _ t � | _ d S)N)r r) �interval�functionr! r" r �finished)r( r� r� r! r" r r r r) � s zTimer.__init__c C s | j j � d S)z)Stop the timer if it hasn't finished yet.N)r� rb )r( r r r �cancel� s z Timer.cancelc C sL | j j | j � | j j � s; | j | j | j � n | j j � d S)N)r� rR r� ra r� r! r" rb )r( r r r r� � s z Timer.run)r. rC rD rE r) r� r� r r r r r � s c @ s e Z d Z d d � Z d S)� _MainThreadc C sX t j | d d d d �| j � | j j � | j � t � | t | j <Wd QXd S)Nr+ Z MainThreadr| F) r r) r� r� rb r� r� r* r� )r( r r r r) � s z_MainThread.__init__N)r. rC rD r) r r r r r� � s r� c @ s7 e Z d Z d d � Z d d � Z d d d � Z d S)� _DummyThreadc C sT t j | d t d � d d �| j j � | j � t � | t | j <Wd QXd S)Nr+ zDummy-%dr| T) r r) r{ r� rb r� r� r* r� )r( r r r r) � s z_DummyThread.__init__c C s d S)Nr )r( r r r r� � s z_DummyThread._stopNc C s d S)Nr )r( r5 r r r r� � s z_DummyThread.join)r. rC rD r) r� r� r r r r r� � s r� c C s/ y t t � SWn t k r* t � SYn Xd S)z�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* r2 r, r� r r r r r � s c C s% t � t t � t t � SWd QXd S)z�Return the number of Thread objects currently alive. The returned count is equal to the length of the list returned by enumerate(). N)r� rL r* r� r r r r r � s c C s t t j � � t t j � � S)N)�listr* �valuesr� r r r r � _enumerate� s r� c C s1 t �% t t j � � t t j � � SWd QXd S)z�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� r� r r r r r � s )r c C sT t j } | j � t j � t � } x | rE | j � t � } q) Wt j � d S)N)� _main_threadr� r9 r� �_pickSomeNonDaemonThreadr� r� )Ztlockr: r r r � _shutdown� s r� c C s2 x+ t � D] } | j r | j � r | Sq Wd S)N)r r| r� )r: r r r r� s r� c C s t S)z�Return the main thread object. In normal conditions, the main thread is the thread from which the Python interpreter was started. )r� r r r r � main_thread s r� )�_local)r c C s� t � a i } t � } | a t �� t t � � } | j t � x] | D]U } | | k r� | j d � t � } | | _ | | | <qH | j d � | j � qH Wt j � t j � t j | � Wd QXd S)NTF)r$ r� r r� rb r� �updater� r` r2 r� r� r� rc r* )Z new_activeZcurrentZthreadsZthreadr� r r r � _after_fork s& r� )KrE �sysr� �_threadr r rS � ImportError� tracebackr r� � _weakrefsetr � itertoolsr rW r r' � _collectionsr rI � collections�__all__�start_new_threadr� � allocate_lockr$ r� r2 �errorr r r rH � TIMEOUT_MAXr r r r r r# r r r r r r r8 ro �__next__ry r{ r� r* r� r� r r r� r� r Z currentThreadr Z activeCountr� r r r� r� r� r� r� r Z_threading_localr� r r r r �<module> s� k�P&O� � �
Submit
FILE
FOLDER
Name
Size
Permission
Action
__future__.cpython-34.pyc
4168 bytes
0644
__future__.cpython-34.pyo
4168 bytes
0644
__phello__.foo.cpython-34.pyc
134 bytes
0644
__phello__.foo.cpython-34.pyo
134 bytes
0644
_bootlocale.cpython-34.pyc
1047 bytes
0644
_bootlocale.cpython-34.pyo
1016 bytes
0644
_collections_abc.cpython-34.pyc
23949 bytes
0644
_collections_abc.cpython-34.pyo
23949 bytes
0644
_compat_pickle.cpython-34.pyc
7501 bytes
0644
_compat_pickle.cpython-34.pyo
7427 bytes
0644
_dummy_thread.cpython-34.pyc
4825 bytes
0644
_dummy_thread.cpython-34.pyo
4825 bytes
0644
_markupbase.cpython-34.pyc
8932 bytes
0644
_markupbase.cpython-34.pyo
8745 bytes
0644
_osx_support.cpython-34.pyc
10630 bytes
0644
_osx_support.cpython-34.pyo
10630 bytes
0644
_pyio.cpython-34.pyc
64933 bytes
0644
_pyio.cpython-34.pyo
64907 bytes
0644
_sitebuiltins.cpython-34.pyc
3677 bytes
0644
_sitebuiltins.cpython-34.pyo
3677 bytes
0644
_strptime.cpython-34.pyc
15779 bytes
0644
_strptime.cpython-34.pyo
15779 bytes
0644
_sysconfigdata.cpython-34.pyc
22409 bytes
0644
_sysconfigdata.cpython-34.pyo
22409 bytes
0644
_threading_local.cpython-34.pyc
6946 bytes
0644
_threading_local.cpython-34.pyo
6946 bytes
0644
_weakrefset.cpython-34.pyc
8465 bytes
0644
_weakrefset.cpython-34.pyo
8465 bytes
0644
abc.cpython-34.pyc
7877 bytes
0644
abc.cpython-34.pyo
7827 bytes
0644
aifc.cpython-34.pyc
27912 bytes
0644
aifc.cpython-34.pyo
27912 bytes
0644
antigravity.cpython-34.pyc
847 bytes
0644
antigravity.cpython-34.pyo
847 bytes
0644
argparse.cpython-34.pyc
65874 bytes
0644
argparse.cpython-34.pyo
65715 bytes
0644
ast.cpython-34.pyc
12360 bytes
0644
ast.cpython-34.pyo
12360 bytes
0644
asynchat.cpython-34.pyc
8359 bytes
0644
asynchat.cpython-34.pyo
8359 bytes
0644
asyncore.cpython-34.pyc
17963 bytes
0644
asyncore.cpython-34.pyo
17963 bytes
0644
base64.cpython-34.pyc
18297 bytes
0644
base64.cpython-34.pyo
18099 bytes
0644
bdb.cpython-34.pyc
18694 bytes
0644
bdb.cpython-34.pyo
18694 bytes
0644
binhex.cpython-34.pyc
13541 bytes
0644
binhex.cpython-34.pyo
13541 bytes
0644
bisect.cpython-34.pyc
2858 bytes
0644
bisect.cpython-34.pyo
2858 bytes
0644
bz2.cpython-34.pyc
15156 bytes
0644
bz2.cpython-34.pyo
15156 bytes
0644
cProfile.cpython-34.pyc
4622 bytes
0644
cProfile.cpython-34.pyo
4622 bytes
0644
calendar.cpython-34.pyc
27567 bytes
0644
calendar.cpython-34.pyo
27567 bytes
0644
cgi.cpython-34.pyc
29827 bytes
0644
cgi.cpython-34.pyo
29827 bytes
0644
cgitb.cpython-34.pyc
11064 bytes
0644
cgitb.cpython-34.pyo
11064 bytes
0644
chunk.cpython-34.pyc
5270 bytes
0644
chunk.cpython-34.pyo
5270 bytes
0644
cmd.cpython-34.pyc
13456 bytes
0644
cmd.cpython-34.pyo
13456 bytes
0644
code.cpython-34.pyc
9702 bytes
0644
code.cpython-34.pyo
9702 bytes
0644
codecs.cpython-34.pyc
35132 bytes
0644
codecs.cpython-34.pyo
35132 bytes
0644
codeop.cpython-34.pyc
6466 bytes
0644
codeop.cpython-34.pyo
6466 bytes
0644
colorsys.cpython-34.pyc
3659 bytes
0644
colorsys.cpython-34.pyo
3659 bytes
0644
compileall.cpython-34.pyc
7378 bytes
0644
compileall.cpython-34.pyo
7378 bytes
0644
configparser.cpython-34.pyc
44882 bytes
0644
configparser.cpython-34.pyo
44882 bytes
0644
contextlib.cpython-34.pyc
10370 bytes
0644
contextlib.cpython-34.pyo
10370 bytes
0644
copy.cpython-34.pyc
8061 bytes
0644
copy.cpython-34.pyo
7975 bytes
0644
copyreg.cpython-34.pyc
4607 bytes
0644
copyreg.cpython-34.pyo
4566 bytes
0644
crypt.cpython-34.pyc
2437 bytes
0644
crypt.cpython-34.pyo
2437 bytes
0644
csv.cpython-34.pyc
12997 bytes
0644
csv.cpython-34.pyo
12997 bytes
0644
datetime.cpython-34.pyc
56264 bytes
0644
datetime.cpython-34.pyo
54296 bytes
0644
decimal.cpython-34.pyc
172526 bytes
0644
decimal.cpython-34.pyo
172526 bytes
0644
difflib.cpython-34.pyc
60515 bytes
0644
difflib.cpython-34.pyo
60467 bytes
0644
dis.cpython-34.pyc
14587 bytes
0644
dis.cpython-34.pyo
14587 bytes
0644
doctest.cpython-34.pyc
80110 bytes
0644
doctest.cpython-34.pyo
79837 bytes
0644
dummy_threading.cpython-34.pyc
1214 bytes
0644
dummy_threading.cpython-34.pyo
1214 bytes
0644
enum.cpython-34.pyc
16339 bytes
0644
enum.cpython-34.pyo
16339 bytes
0644
filecmp.cpython-34.pyc
9120 bytes
0644
filecmp.cpython-34.pyo
9120 bytes
0644
fileinput.cpython-34.pyc
14297 bytes
0644
fileinput.cpython-34.pyo
14297 bytes
0644
fnmatch.cpython-34.pyc
3146 bytes
0644
fnmatch.cpython-34.pyo
3146 bytes
0644
formatter.cpython-34.pyc
18916 bytes
0644
formatter.cpython-34.pyo
18916 bytes
0644
fractions.cpython-34.pyc
19270 bytes
0644
fractions.cpython-34.pyo
19270 bytes
0644
ftplib.cpython-34.pyc
33322 bytes
0644
ftplib.cpython-34.pyo
33322 bytes
0644
functools.cpython-34.pyc
23614 bytes
0644
functools.cpython-34.pyo
23614 bytes
0644
genericpath.cpython-34.pyc
3493 bytes
0644
genericpath.cpython-34.pyo
3493 bytes
0644
getopt.cpython-34.pyc
6733 bytes
0644
getopt.cpython-34.pyo
6691 bytes
0644
getpass.cpython-34.pyc
4624 bytes
0644
getpass.cpython-34.pyo
4624 bytes
0644
gettext.cpython-34.pyc
15174 bytes
0644
gettext.cpython-34.pyo
15174 bytes
0644
glob.cpython-34.pyc
2880 bytes
0644
glob.cpython-34.pyo
2880 bytes
0644
gzip.cpython-34.pyc
19446 bytes
0644
gzip.cpython-34.pyo
19392 bytes
0644
hashlib.cpython-34.pyc
7944 bytes
0644
hashlib.cpython-34.pyo
7944 bytes
0644
heapq.cpython-34.pyc
13910 bytes
0644
heapq.cpython-34.pyo
13910 bytes
0644
hmac.cpython-34.pyc
5146 bytes
0644
hmac.cpython-34.pyo
5146 bytes
0644
imaplib.cpython-34.pyc
43479 bytes
0644
imaplib.cpython-34.pyo
40955 bytes
0644
imghdr.cpython-34.pyc
4143 bytes
0644
imghdr.cpython-34.pyo
4143 bytes
0644
imp.cpython-34.pyc
9867 bytes
0644
imp.cpython-34.pyo
9867 bytes
0644
inspect.cpython-34.pyc
76327 bytes
0644
inspect.cpython-34.pyo
76006 bytes
0644
io.cpython-34.pyc
3458 bytes
0644
io.cpython-34.pyo
3458 bytes
0644
ipaddress.cpython-34.pyc
62984 bytes
0644
ipaddress.cpython-34.pyo
62984 bytes
0644
keyword.cpython-34.pyc
1946 bytes
0644
keyword.cpython-34.pyo
1946 bytes
0644
linecache.cpython-34.pyc
3112 bytes
0644
linecache.cpython-34.pyo
3112 bytes
0644
locale.cpython-34.pyc
37276 bytes
0644
locale.cpython-34.pyo
37276 bytes
0644
lzma.cpython-34.pyc
15917 bytes
0644
lzma.cpython-34.pyo
15917 bytes
0644
macpath.cpython-34.pyc
6006 bytes
0644
macpath.cpython-34.pyo
6006 bytes
0644
macurl2path.cpython-34.pyc
2102 bytes
0644
macurl2path.cpython-34.pyo
2102 bytes
0644
mailbox.cpython-34.pyc
70288 bytes
0644
mailbox.cpython-34.pyo
70189 bytes
0644
mailcap.cpython-34.pyc
6544 bytes
0644
mailcap.cpython-34.pyo
6544 bytes
0644
mimetypes.cpython-34.pyc
16807 bytes
0644
mimetypes.cpython-34.pyo
16807 bytes
0644
modulefinder.cpython-34.pyc
17376 bytes
0644
modulefinder.cpython-34.pyo
17297 bytes
0644
netrc.cpython-34.pyc
4277 bytes
0644
netrc.cpython-34.pyo
4277 bytes
0644
nntplib.cpython-34.pyc
36310 bytes
0644
nntplib.cpython-34.pyo
36310 bytes
0644
ntpath.cpython-34.pyc
13305 bytes
0644
ntpath.cpython-34.pyo
13305 bytes
0644
nturl2path.cpython-34.pyc
1716 bytes
0644
nturl2path.cpython-34.pyo
1716 bytes
0644
numbers.cpython-34.pyc
12667 bytes
0644
numbers.cpython-34.pyo
12667 bytes
0644
opcode.cpython-34.pyc
5174 bytes
0644
opcode.cpython-34.pyo
5174 bytes
0644
operator.cpython-34.pyc
12778 bytes
0644
operator.cpython-34.pyo
12778 bytes
0644
optparse.cpython-34.pyc
51537 bytes
0644
optparse.cpython-34.pyo
51460 bytes
0644
os.cpython-34.pyc
29599 bytes
0644
os.cpython-34.pyo
29599 bytes
0644
pathlib.cpython-34.pyc
40483 bytes
0644
pathlib.cpython-34.pyo
40483 bytes
0644
pdb.cpython-34.pyc
49472 bytes
0644
pdb.cpython-34.pyo
49406 bytes
0644
pickle.cpython-34.pyc
46984 bytes
0644
pickle.cpython-34.pyo
46838 bytes
0644
pickletools.cpython-34.pyc
70254 bytes
0644
pickletools.cpython-34.pyo
69167 bytes
0644
pipes.cpython-34.pyc
8431 bytes
0644
pipes.cpython-34.pyo
8431 bytes
0644
pkgutil.cpython-34.pyc
17600 bytes
0644
pkgutil.cpython-34.pyo
17600 bytes
0644
platform.cpython-34.pyc
31172 bytes
0644
platform.cpython-34.pyo
31172 bytes
0644
plistlib.cpython-34.pyc
30151 bytes
0644
plistlib.cpython-34.pyo
30068 bytes
0644
poplib.cpython-34.pyc
13754 bytes
0644
poplib.cpython-34.pyo
13754 bytes
0644
posixpath.cpython-34.pyc
9809 bytes
0644
posixpath.cpython-34.pyo
9809 bytes
0644
pprint.cpython-34.pyc
11460 bytes
0644
pprint.cpython-34.pyo
11295 bytes
0644
profile.cpython-34.pyc
15151 bytes
0644
profile.cpython-34.pyo
14898 bytes
0644
pstats.cpython-34.pyc
23675 bytes
0644
pstats.cpython-34.pyo
23675 bytes
0644
pty.cpython-34.pyc
4225 bytes
0644
pty.cpython-34.pyo
4225 bytes
0644
py_compile.cpython-34.pyc
6857 bytes
0644
py_compile.cpython-34.pyo
6857 bytes
0644
pyclbr.cpython-34.pyc
9192 bytes
0644
pyclbr.cpython-34.pyo
9192 bytes
0644
pydoc.cpython-34.pyc
90915 bytes
0644
pydoc.cpython-34.pyo
90854 bytes
0644
queue.cpython-34.pyc
9262 bytes
0644
queue.cpython-34.pyo
9262 bytes
0644
quopri.cpython-34.pyc
6446 bytes
0644
quopri.cpython-34.pyo
6236 bytes
0644
random.cpython-34.pyc
19059 bytes
0644
random.cpython-34.pyo
19059 bytes
0644
re.cpython-34.pyc
14550 bytes
0644
re.cpython-34.pyo
14550 bytes
0644
reprlib.cpython-34.pyc
5872 bytes
0644
reprlib.cpython-34.pyo
5872 bytes
0644
rlcompleter.cpython-34.pyc
5695 bytes
0644
rlcompleter.cpython-34.pyo
5695 bytes
0644
runpy.cpython-34.pyc
7753 bytes
0644
runpy.cpython-34.pyo
7753 bytes
0644
sched.cpython-34.pyc
6573 bytes
0644
sched.cpython-34.pyo
6573 bytes
0644
selectors.cpython-34.pyc
16744 bytes
0644
selectors.cpython-34.pyo
16744 bytes
0644
shelve.cpython-34.pyc
9955 bytes
0644
shelve.cpython-34.pyo
9955 bytes
0644
shlex.cpython-34.pyc
7518 bytes
0644
shlex.cpython-34.pyo
7518 bytes
0644
shutil.cpython-34.pyc
33015 bytes
0644
shutil.cpython-34.pyo
33015 bytes
0644
site.cpython-34.pyc
17971 bytes
0644
site.cpython-34.pyo
17971 bytes
0644
smtpd.cpython-34.pyc
25669 bytes
0644
smtpd.cpython-34.pyo
25669 bytes
0644
smtplib.cpython-34.pyc
33129 bytes
0644
smtplib.cpython-34.pyo
33055 bytes
0644
sndhdr.cpython-34.pyc
6769 bytes
0644
sndhdr.cpython-34.pyo
6769 bytes
0644
socket.cpython-34.pyc
18111 bytes
0644
socket.cpython-34.pyo
18061 bytes
0644
socketserver.cpython-34.pyc
23255 bytes
0644
socketserver.cpython-34.pyo
23255 bytes
0644
sre_compile.cpython-34.pyc
11935 bytes
0644
sre_compile.cpython-34.pyo
11778 bytes
0644
sre_constants.cpython-34.pyc
5581 bytes
0644
sre_constants.cpython-34.pyo
5581 bytes
0644
sre_parse.cpython-34.pyc
20238 bytes
0644
sre_parse.cpython-34.pyo
20238 bytes
0644
ssl.cpython-34.pyc
27536 bytes
0644
ssl.cpython-34.pyo
27536 bytes
0644
stat.cpython-34.pyc
3578 bytes
0644
stat.cpython-34.pyo
3578 bytes
0644
statistics.cpython-34.pyc
17158 bytes
0644
statistics.cpython-34.pyo
16856 bytes
0644
string.cpython-34.pyc
8376 bytes
0644
string.cpython-34.pyo
8376 bytes
0644
stringprep.cpython-34.pyc
13636 bytes
0644
stringprep.cpython-34.pyo
13573 bytes
0644
struct.cpython-34.pyc
347 bytes
0644
struct.cpython-34.pyo
347 bytes
0644
subprocess.cpython-34.pyc
43359 bytes
0644
subprocess.cpython-34.pyo
43246 bytes
0644
sunau.cpython-34.pyc
18309 bytes
0644
sunau.cpython-34.pyo
18309 bytes
0644
symbol.cpython-34.pyc
2662 bytes
0644
symbol.cpython-34.pyo
2662 bytes
0644
symtable.cpython-34.pyc
11305 bytes
0644
symtable.cpython-34.pyo
11183 bytes
0644
sysconfig.cpython-34.pyc
17287 bytes
0644
sysconfig.cpython-34.pyo
17287 bytes
0644
tabnanny.cpython-34.pyc
7749 bytes
0644
tabnanny.cpython-34.pyo
7749 bytes
0644
tarfile.cpython-34.pyc
68040 bytes
0644
tarfile.cpython-34.pyo
68040 bytes
0644
telnetlib.cpython-34.pyc
19394 bytes
0644
telnetlib.cpython-34.pyo
19394 bytes
0644
tempfile.cpython-34.pyc
21576 bytes
0644
tempfile.cpython-34.pyo
21576 bytes
0644
textwrap.cpython-34.pyc
13800 bytes
0644
textwrap.cpython-34.pyo
13714 bytes
0644
this.cpython-34.pyc
1316 bytes
0644
this.cpython-34.pyo
1316 bytes
0644
threading.cpython-34.pyc
38965 bytes
0644
threading.cpython-34.pyo
38252 bytes
0644
timeit.cpython-34.pyc
11062 bytes
0644
timeit.cpython-34.pyo
11062 bytes
0644
token.cpython-34.pyc
3615 bytes
0644
token.cpython-34.pyo
3615 bytes
0644
tokenize.cpython-34.pyc
19951 bytes
0644
tokenize.cpython-34.pyo
19901 bytes
0644
trace.cpython-34.pyc
24184 bytes
0644
trace.cpython-34.pyo
24127 bytes
0644
traceback.cpython-34.pyc
11091 bytes
0644
traceback.cpython-34.pyo
11091 bytes
0644
tracemalloc.cpython-34.pyc
17130 bytes
0644
tracemalloc.cpython-34.pyo
17130 bytes
0644
tty.cpython-34.pyc
1146 bytes
0644
tty.cpython-34.pyo
1146 bytes
0644
types.cpython-34.pyc
5560 bytes
0644
types.cpython-34.pyo
5560 bytes
0644
uu.cpython-34.pyc
4021 bytes
0644
uu.cpython-34.pyo
4021 bytes
0644
uuid.cpython-34.pyc
21864 bytes
0644
uuid.cpython-34.pyo
21802 bytes
0644
warnings.cpython-34.pyc
12268 bytes
0644
warnings.cpython-34.pyo
11536 bytes
0644
wave.cpython-34.pyc
19135 bytes
0644
wave.cpython-34.pyo
19074 bytes
0644
weakref.cpython-34.pyc
20345 bytes
0644
weakref.cpython-34.pyo
20308 bytes
0644
webbrowser.cpython-34.pyc
17132 bytes
0644
webbrowser.cpython-34.pyo
17093 bytes
0644
xdrlib.cpython-34.pyc
9002 bytes
0644
xdrlib.cpython-34.pyo
9002 bytes
0644
zipfile.cpython-34.pyc
45820 bytes
0644
zipfile.cpython-34.pyo
45771 bytes
0644
N4ST4R_ID | Naxtarrr
