File: //usr/local/lib/python3.9/site-packages/vine/__pycache__/synchronization.cpython-39.pyc
a
X>h� � @ s> d Z ddlmZ ddlmZ dgZG dd� d�Ze�e� dS )zSynchronization primitives.� )�Thenable)�promise�barrierc @ sX e Zd ZdZddd�Zdd� Zdd� Zd d
� Zd d � Zd
d� Z ddd�Z
dd� Z e Z dS )r a� Barrier.
Synchronization primitive to call a callback after a list
of promises have been fulfilled.
Example:
.. code-block:: python
# Request supports the .then() method.
p1 = http.Request('http://a')
p2 = http.Request('http://b')
p3 = http.Request('http://c')
requests = [p1, p2, p3]
def all_done():
pass # all requests complete
b = barrier(requests).then(all_done)
# oops, we forgot we want another request
b.add(http.Request('http://d'))
Note that you cannot add new promises to a barrier after
the barrier is fulfilled.
Nc s� t � � _|pd� _|pi � _d� _|p(d� _� jsL|rL|�� }|turL|� _d � _� _ d � _
d� _ d� _ � fdd�|pzg D � t
|p�� j�� _ |r�� �|� d}d S )N� � Fc s g | ]}� � |��qS r )�
add_noincr)�.0�p��selfr �>/usr/local/lib/python3.9/site-packages/vine/synchronization.py�
<listcomp>7 � z$barrier.__init__.<locals>.<listcomp>) r �args�kwargs�_value�size�ready�reason� cancelled� finalized� __weakref__�__dict__)r r r r r r �__len__�NotImplementedr �failedr r r �bool�then)r �promisesr r �callbackr �plen� __slots__r r
r �__init__$ s$
zbarrier.__init__c O sJ | j sF| jsF| jd7 _| jrF| j| jkrFd| _ | j| ji | j�� d S )Nr T)r r r r r r r r �r r r r r r �__call__D s
zbarrier.__call__c C s0 | j s&| j| jkr&| j| ji | j�� d| _ d S �NT)r r r r r r r
r r r �finalizeK s zbarrier.finalizec C s d| _ | j�� d S r% )r r �cancelr
r r r r' P s zbarrier.cancelc C s" | j s | jrtd��|�| � d S )Nz"Cannot add promise to full barrier)r r �
ValueErrorr �r r r r r r T s zbarrier.add_noincrc C s" | j s | �|� | jd7 _d S )Nr )r r r r) r r r �addZ s
z barrier.addc C s | j �||� d S �N)r r )r r Zerrbackr r r r _ s z barrier.thenc O s | j s| jj|i |�� d S r+ )r r �throwr# r r r r, b s z
barrier.throw)NNNNN)N)
�__name__�
__module__� __qualname__�__doc__r" r$ r& r' r r* r r, Zthrow1r r r r r s �
N)r0 Zabstractr r r �__all__r �registerr r r r �<module> s
`