Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/twisted/_threads/__pycache__/_threadworker.cpython-39.pyc
Ðазад
a k�h� � @ s^ d Z ddlmZ ddlmZ ddlmZ e� Zee�G dd� d��Z ee�G dd � d ��Z d S ) zE Implementation of an L{IWorker} based on native threads and queues. � )� implementer� )�Quit)�IExclusiveWorkerc @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � ThreadWorkerz� An L{IExclusiveWorker} implemented based on a single thread and a queue. This worker ensures exclusivity (i.e. it is an L{IExclusiveWorker} and not an L{IWorker}) by performing all of the work passed to C{do} on the I{same} thread. c s& � | _ t� | _� fdd�}||� dS )a� Create a L{ThreadWorker} with a function to start a thread and a queue to use to communicate with that thread. @param startThread: a callable that takes a callable to run in another thread. @type startThread: callable taking a 0-argument callable and returning nothing. @param queue: A L{Queue} to use to give tasks to the thread created by C{startThread}. @type queue: L{Queue} c s t � jt�D ] } | � q d S )N)�iter�get�_stop)�task��queue� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/twisted/_threads/_threadworker.py�work- s z#ThreadWorker.__init__.<locals>.workN)�_qr �_hasQuit)�selfZ startThreadr r r r r �__init__ s zThreadWorker.__init__c C s | j �� | j�|� dS )z� Perform the given task on the thread owned by this L{ThreadWorker}. @param task: the function to call on a thread. N)r �checkr �put)r r r r r �do3 s zThreadWorker.doc C s | j �� | j�t� dS )zT Reject all future work and stop the thread started by C{__init__}. N)r �setr r r �r r r r �quit< s zThreadWorker.quitN��__name__� __module__� __qualname__�__doc__r r r r r r r r s r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � LockWorkerzE An L{IWorker} implemented based on a mutual-exclusion lock. c C s t � | _|| _|| _dS )z� @param lock: A mutual-exclusion lock, with C{acquire} and C{release} methods. @type lock: L{threading.Lock} @param local: Local storage. @type local: L{threading.local} N)r �_quit�_lock�_local)r �lock�localr r r r L s zLockWorker.__init__c C s� | j }| j}| j�� t|dd�}|du r~g }|_|�|� |�� z$|rZ|�d�� qHW |� � d|_q�|� � d|_0 n |�|� dS )z� Do the given work on this thread, with the mutex acquired. If this is called re-entrantly, return and wait for the outer invocation to do the work. @param work: the work to do with the lock held. �workingNr ) r! r" r r �getattrr% �append�acquire�pop�release)r r r# r$ r% r r r r Y s � z LockWorker.doc C s | j �� d| _dS )z* Quit this L{LockWorker}. N)r r r! r r r r r r s zLockWorker.quitNr r r r r r F s r N) r Zzope.interfacer Z _conveniencer Z _ithreadsr �objectr r r r r r r �<module> s 3
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка