o n�nh$ �@s�UdZddlmZddlmZddlZddlZddlZddl Z ddl Z ddlZej dejdejfd�ZGdd�de j�Zddd�Ze ��ZiZd ed<ejddd��ZdS)zPython threading tools.�)�annotationsN� TCallable.)�boundcs6eZdZdZd �fdd�Zddd �Zddd�Z�ZS)� WrappedThreadz.wrapper)� threading�Lock� functools�wraps)r%r*rr(r�mutex3sr/zdict[str, threading.Lock]� __named_locks�name�str�c.Iterator[bool]ccs~�t�t�|�}rd}n d}t��}t|<Wd�n1s"wY|�|VWd�dS1s8wYdS)z� Context manager that provides named locks using threading.Lock instances. Once named lock instances are created they are not deleted. Returns True if this is the first instance of the named lock, otherwise False. FTN)�__named_lockr0rr+r,)r1� lock_instance�firstrrr� named_lockDs��"�r7)r%rrr)r1r2rr3)r#� __future__r�collections.abc�abc�c� contextlibr-rr+r�typing�t�TypeVar�Callable�Anyr�Threadrr/r,r4r0�__annotations__�contextmanagerr7rrrr�s #