/usr/lib/python3/dist-packages/twisted/python/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/python/__pycache__/threadable.cpython-310.pyc (3520B)
o
¯bÿ ã @ sÀ d Z ddlmZ G dd„ dƒZdd„ Zde_dd „ Zd
d „ Zd d
„ Zdd„ Z d dd„Z
e ƒ Z dd„ Z
dd„ Zdd„ ZdadadadazddlZW n eyS dZY nw eZe
dƒ g d¢ZdS ) zT
A module to provide some very basic threading primitives, such as
synchronization.
é ©Úwrapsc @ s e Zd ZdZdd„ ZdS )Ú DummyLockzF
Hack to allow locks to be unpickled on an unthreaded system.
c C ó t dfS ©N© ©Ú
unpickle_lock©Úselfr r ú;/usr/lib/python3/dist-packages/twisted/python/threadable.pyÚ
__reduce__ ó zDummyLock.__reduce__N)Ú__name__Ú
__module__Ú __qualname__Ú__doc__r
r r r r r s r c C s t d urtƒ S tƒ S ©N)ÚthreadingmoduleÚXLockr r r r r r s r Tc C s> d| j vrt ¡ d| j vrtƒ | j d< t ¡ | j ¡ d S )NÚ_threadable_lock)Ú__dict__Ú_synchLockCreatorÚacquirer Úreleaser r
r r r Ú _synchPre! s
r c C s | j ¡ d S r )r r r
r r r Ú
_synchPost* s r c s t ˆ ƒ‡ fdd„ƒ}|S )Nc s4 t | ƒ zˆ | g|¢R i |¤ŽW t| ƒ S t| ƒ w r )r r )r ÚargsÚkwargs©Úfunctionr r Úsync/ s z_sync.
.syncr )Úklassr r! r r r Ú_sync. s r# c G sB t dur | D ]}|jD ]}t||j| ƒ}t|||ƒ q qdS dS )a&
Make all methods listed in each class' synchronized attribute synchronized.
The synchronized attribute should be a list of strings, consisting of the
names of methods that must be synchronized. If we are running in threaded
mode these methods will be wrapped with a lock.
N)r Ú synchronizedr# r Úsetattr)Úklassesr" Ú
methodNamer! r r r Ú synchronize: s
þþr( é c C sN | r t s tdurda G dd„ dtjƒatƒ adS tdƒ‚dS t r$tdƒ‚ dS )zbInitialize threading.
Don't bother calling this. If it needs to happen, it will happen.
NTc @ s e Zd Zdd„ ZdS )r c S r r r r
r r r r
V r zXLock.__reduce__N)r r r r
r r r r r U s r z:Cannot initialize threading, platform lacks thread supportzCannot uninitialize threads)Úthreadedr Ú_RLockr r Ú RuntimeError)Ú with_threadsr r r ÚinitI s
ÿör. c C s t d u rtS t ¡ jS r )r Ú_dummyIDÚcurrent_threadÚidentr r r r Ú getThreadIDh s
r2 c C s
t tƒ kS )zCAre we in the thread responsible for I/O requests (the event loop)?)ÚioThreadr2 r r r r Ú isInIOThreadn s
r4 c C s
t ƒ adS )z8Mark the current thread as responsible for I/O requests.N)r2 r3 r r r r ÚregisterAsIOThreads s
r5 NF)r4 r5 r2 r )r) )r Ú functoolsr r r Ú__safe_for_unpickling__r r r# r( r. Úobjectr/ r2 r4 r5 r3 r* r r Ú threadingÚ_threadingmoduleÚ ImportErrorr Ú__all__r r r r Ú s4
ÿ