usb-0000:00:01.2-1/input0 $ lY>ٔna&Tţ h.? a i@sdZddlZddlZddlZddlZddlmZ ddl m Z ddl m ZmZzddlmZWneyzddlmZYn0gdZejZejZejZejZzejZdZed Wne yd ZYn0ej!Z"z ej#Z$Wne ydZ$Yn0ej%Z%[da&da'd d Z(d dZ)eZ*ddZ#GdddZ+e+Z,GdddZ-GdddZ.Gddde.Z/GdddZ0GdddZ1Gddde2Z3ej4Z5e5dKd d!Z6e#a7iZ8iZ9e Z:ea;e<a=d"d#Z>Gd$d%d%Z?zdd&lm@aAmBZCWnFey2dd'lDmEZFdd(lmGZGeGd)d*ZBd+d)ZCd,d-aAYn0d.d/ZHGd0d1d1e?ZIGd2d3d3e?ZJGd4d5d5e?ZKd6d7ZLeLZMd8d9ZNeNZOd:d;ZPdd?ZTdd@lmUZUeJaVdAdBZWdCdDZXzddElmYZZWn eyddFl[mZZZYn0dGdHZ\e]edIrej^e\dJdS)Lz;Thread module emulating a subset of Java's threading model.N) monotonic)WeakSet)islicecount)deque) get_ident active_count Conditioncurrent_thread enumerate main_thread TIMEOUT_MAXEventLockRLock SemaphoreBoundedSemaphoreThreadBarrierBrokenBarrierErrorTimer ThreadError setprofilesettracelocal stack_size excepthookExceptHookArgsT get_native_idFcCs|adS)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_hookfuncr"!/usr/lib64/python3.9/threading.pyr:srcCs|adS)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_hookr r"r"r#rDsrcOs$tdurt|i|St|i|S)a2Factory 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#rRs rc@s^eZdZdZddZddZddZdd d ZeZd d Z ddZ ddZ ddZ ddZ dS)_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. cCst|_d|_d|_dSNr)_allocate_lock_block_owner_countselfr"r"r#__init__isz_RLock.__init__c Cs\|j}zt|j}Wnty&Yn0d|jr8dnd|jj|jj||j t t |fS)Nz)<%s %s.%s object owner=%r count=%d at %s>lockedunlocked) r-_activenameKeyErrorr,r2 __class__ __module__ __qualname__r.hexid)r0ownerr"r"r#__repr__ns  z_RLock.__repr__cCs|jd|_d|_dSr*)r,_at_fork_reinitr-r.r/r"r"r#r>}s z_RLock._at_fork_reinitTcCsDt}|j|kr"|jd7_dS|j||}|r@||_d|_|S)aAcquire 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 l