File: //usr/lib/python3/dist-packages/twisted/python/__pycache__/threadable.cpython-38.pyc
U
�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� Zdadadadaz ddlZW n ek
r� dZY nX eZe
d� ddddgZdS ) 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 s t dfS �N� ��
unpickle_lock��selfr r �;/usr/lib/python3/dist-packages/twisted/python/threadable.py�
__reduce__ s zDummyLock.__reduce__N)�__name__�
__module__� __qualname__�__doc__r r r r r r s r c C s t d k rt� S t� S d S �N)�threadingmodule�XLockr r r r r r s r Tc C s> d| j kr0t�� d| j kr(t� | 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 s, t | � z� | f|�|�W �S t| � X d S r )r r )r
�args�kwargs��functionr r �sync/ s z_sync.<locals>.syncr )�klassr r r r r �_sync. s r! c G s> t dk r:| D ],}|jD ] }t||j| �}t|||� qq 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)Zklassesr �
methodNamer r r r � synchronize: s
r% � c C sJ | r8t sFtdk r.da G dd� dtj�at� aqFtd��nt rFtd��n 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 s t dfS r r r r r r r V s 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)Z with_threadsr r r �initI s �
r* c C s t d kr tS t �� jS r )r �_dummyID�current_thread�identr r r r � getThreadIDh s r. c C s
t t� kS )zCAre we in the thread responsible for I/O requests (the event loop)?)�ioThreadr. r r r r � isInIOThreadn s r0 c C s
t � adS )z8Mark the current thread as responsible for I/O requests.N)r. r/ r r r r �registerAsIOThreads s r1 NFr )r& )r � functoolsr r r �__safe_for_unpickling__r r r! r% r* �objectr+ r. r0 r1 r/ r' r r � threadingZ_threadingmodule� ImportErrorr �__all__r r r r �<module> s0