xzf @ sU d Z d d l Z d d l Z d d l m Z d 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
r*d 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= d/ d Z> e> Z? d0 d1 Z@ d2 d ZA d d3 l mB ZB e: aC d4 d5 ZD d6 d7 ZE d8 d9 ZF y d d: l mG ZH Wn" e k
rDd d; lI mH ZH Yn Xd< d= ZJ d S)>z;Thread module emulating a subset of Java's threading model. N) monotonic)
format_exc)WeakSet)islicecount)deque active_count Conditioncurrent_thread enumerateEventLockRLock SemaphoreBoundedSemaphoreThreadBarrierTimer ThreadError
setprofilesettracelocal
stack_sizec C s
| a d S)zSet 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/python35/lib64/python3.5/threading.pyr 0 s c C s
| a d S)zSet 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)argskwargsr r r r H 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___ s z_RLock.__init__c C sy | j } y t | j } Wn t k
r. Yn Xd | j j rG d n d | j j | j j | | j t
t | f S)Nz)<%s %s.%s object owner=%r count=%d at %s>lockedZunlocked) r% _activenameKeyErrorr$ r) __class__
__module__ __qualname__r& hexid)r' ownerr r r __repr__d s
z_RLock.__repr__T c C s\ t } | j | k r+ | j d 7_ d S| j j | | } | rX | | _ d | _ | 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.
r4 ) get_identr% r& r$ acquire)r' blockingtimeoutmercr r r r6 s s z_RLock.acquirec C sR | j t k r t d | j d | _ } | sN d | _ | j j 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 lockr4 N)r% r5 RuntimeErrorr& r$ release)r' r r r r r< s z_RLock.releasec C s | j d S)N)r< )r' tvtbr r r __exit__ s z_RLock.__exit__c C s# | j j | \ | _ | _ d S)N)r$ r6 r& r% )r' stater r r _acquire_restore s
z_RLock._acquire_restorec C sV | j d k r t d | j } d | _ | j } d | _ | j j | | f S)Nr z cannot release un-acquired lock)r& r; r% r$ r< )r' r r2 r r r
_release_save s
z_RLock._release_savec C s | j t k S)N)r% r5 )r' r r r _is_owned s z_RLock._is_ownedN)
__name__r. r/ __doc__r( r3 r6 __enter__r< r@ rB rC rD r r r r r" U 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 } | | _ | j | _ | j | _ y | j | _ Wn t k
rZ Yn Xy | j | _ Wn t k
r Yn Xy | j | _ Wn t k
r Yn Xt | _ d S)N)
r _lockr6 r< rC AttributeErrorrB rD _deque_waiters)r' lockr r r r( s$
zCondition.__init__c C s
| j j S)N)rI rH )r' r r r rH s zCondition.__enter__c G s | j j | S)N)rI r@ )r' r r r r r@ s zCondition.__exit__c C s d | j t | j f S)Nz