ikan Uploader :
Directory : /opt/alt/python37/lib64/python3.7/multiprocessing/__pycache__/
Upload File : |
| Current File : //opt/alt/python37/lib64/python3.7/multiprocessing/__pycache__/synchronize.cpython-37.opt-2.pyc |
B
YI~dA- � @ s, d dddddgZ ddlZddlZddlZddlZddlZdd lmZ dd
lmZ dd lm Z ydd lm
Z
m Z W n e k
r� e d
��Y nX e
ed��\ZZej
jZG dd� de�Z
G dd� de
�ZG dd� de�ZG dd � d e
�ZG dd� de
�ZG dd� de�ZG dd� de�ZG dd� dej�ZdS )�Lock�RLock� Semaphore�BoundedSemaphore� Condition�Event� N� )�context)�process)�util)�SemLock�
sem_unlinkz�This platform lacks a functioning sem_open implementation, therefore, the required synchronization primitives needed will not function, see issue 3770.� c @ s\ e Zd Ze�� Zdd� Zedd� �Zdd� Z dd� Z
d d
� Z d d � Z d
d� Z
edd� �ZdS )r c C s� |d krt j�� }|�� }tjdkp*|dk}xPtd�D ]<}y t�|||| � � |� }| _
W n t k
rn Y q6X P q6W t d��t �
d|j � | �� tjdkr�dd� } t �| | � | j
jd k r�dd lm}
|
| j
j� t j| tj| j
jfd
d � d S ) N�win32�fork�d z cannot find name for semaphorez created semlock with handle %sc S s | j �� d S )N)�_semlock� _after_fork)�obj� r �@/opt/alt/python37/lib64/python3.7/multiprocessing/synchronize.pyr G s z%SemLock.__init__.<locals>._after_forkr )�registerr )Z exitpriority)r Z_default_contextZ get_contextZget_start_method�sys�platform�range�_multiprocessingr �
_make_namer �FileExistsErrorr �debug�handle�
_make_methodsZregister_after_fork�name�semaphore_trackerr ZFinalize�_cleanup) �self�kind�value�maxvalue�ctxr! Z
unlink_now�i�slr r r r r �__init__2 s.
zSemLock.__init__c C s ddl m} t| � || � d S )Nr )�
unregister)r" r, r
)r! r, r r r r# T s zSemLock._cleanupc C s | j j| _| j j| _d S )N)r �acquire�release)r$ r r r r Z s
zSemLock._make_methodsc C s
| j �� S )N)r � __enter__)r$ r r r r/ ^ s zSemLock.__enter__c G s | j j|� S )N)r �__exit__)r$ �argsr r r r0 a s zSemLock.__exit__c C sD t �| � | j}tjdkr,t �� �|j�}n|j}||j|j |j
fS )Nr ) r �assert_spawningr r r Zget_spawning_popenZduplicate_for_childr r% r' r! )r$ r* �hr r r � __getstate__d s
zSemLock.__getstate__c C s, t jj|� | _t�d|d � | �� d S )Nz recreated blocker with handle %rr )r r Z_rebuildr r r r )r$ �stater r r � __setstate__m s zSemLock.__setstate__c C s dt �� jd ttj�f S )Nz%s-%sZ semprefix)r
�current_processZ_config�nextr �_randr r r r r r s zSemLock._make_nameN)�__name__�
__module__� __qualname__�tempfileZ_RandomNameSequencer9 r+ � staticmethodr# r r/ r0 r4 r6 r r r r r r . s " r c @ s& e Zd Zd dd�Zdd� Zdd� ZdS )
r r c C s t j| t|t|d� d S )N)r( )r r+ � SEMAPHORE�
SEM_VALUE_MAX)r$ r& r( r r r r+ } s zSemaphore.__init__c C s
| j �� S )N)r �
_get_value)r$ r r r � get_value� s zSemaphore.get_valuec C s8 y| j �� }W n tk
r& d}Y nX d| jj|f S )N�unknownz<%s(value=%s)>)r rA � Exception� __class__r: )r$ r& r r r �__repr__� s
zSemaphore.__repr__N)r )r: r; r< r+ rB rF r r r r r { s
c @ s e Zd Zddd�Zdd� ZdS )r r c C s t j| t|||d� d S )N)r( )r r+ r? )r$ r& r( r r r r+ � s zBoundedSemaphore.__init__c C s> y| j �� }W n tk
r& d}Y nX d| jj|| j jf S )NrC z<%s(value=%s, maxvalue=%s)>)r rA rD rE r: r' )r$ r& r r r rF � s
zBoundedSemaphore.__repr__N)r )r: r; r< r+ rF r r r r r � s
c @ s e Zd Zdd� Zdd� ZdS )r c C s t j| tdd|d� d S )Nr )r( )r r+ r? )r$ r( r r r r+ � s z
Lock.__init__c C s� yf| j �� r8t�� j}t�� jdkrd|dt�� j 7 }n,| j �� dkrLd}n| j �� dkr`d}nd}W n t k
r~ d}Y nX d | j
j |f S )
N�
MainThread�|r �Noner �SomeOtherThread�SomeOtherProcessrC z<%s(owner=%s)>) r �_is_miner
r7 r! � threading�current_threadrA �_countrD rE r: )r$ r! r r r rF � s
z
Lock.__repr__N)r: r; r< r+ rF r r r r r � s c @ s e Zd Zdd� Zdd� ZdS )r c C s t j| tdd|d� d S )Nr )r( )r r+ �RECURSIVE_MUTEX)r$ r( r r r r+ � s zRLock.__init__c C s� y|| j �� rBt�� j}t�� jdkr6|dt�� j 7 }| j �� }n8| j �� dkrZd\}}n | j �� dkrrd\}}nd\}}W n t k
r� d\}}Y nX d | j
j ||f S )
NrG rH r )rI r r )rJ �nonzero)rK rQ )rC rC z <%s(%s, %s)>) r rL r
r7 r! rM rN rO rA rD rE r: )r$ r! �countr r r rF � s
zRLock.__repr__N)r: r; r< r+ rF r r r r r � s c @ sl e Zd Zddd�Zdd� Zdd� Zdd � Zd
d � Zd d
� Zdd� Z ddd�Z
ddd�Z dd� Z d dd�Z
dS ) r Nc C s> |p
|� � | _|�d�| _|�d�| _|�d�| _| �� d S )Nr )r �_lockr �_sleeping_count� _woken_count�_wait_semaphorer )r$ �lockr( r r r r+ � s
zCondition.__init__c C s t �| � | j| j| j| jfS )N)r r2 rS rT rU rV )r$ r r r r4 � s
zCondition.__getstate__c C s |\| _ | _| _| _| �� d S )N)rS rT rU rV r )r$ r5 r r r r6 � s zCondition.__setstate__c C s
| j �� S )N)rS r/ )r$ r r r r/ � s zCondition.__enter__c G s | j j|� S )N)rS r0 )r$ r1 r r r r0 � s zCondition.__exit__c C s | j j| _| j j| _d S )N)rS r- r. )r$ r r r r � s
zCondition._make_methodsc C sJ y | j j�� | jj�� }W n tk
r4 d}Y nX d| jj| j|f S )NrC z <%s(%s, %s)>)rT r rA rU rD rE r: rS )r$ Z num_waitersr r r rF � s
zCondition.__repr__c C sn | j �� | jj�� }xt|�D ]}| j�� q W z| j�d|�S | j�� xt|�D ]}| j�� qVW X d S )NT) rT r. rS r rO r rV r- rU )r$ �timeoutrR r) r r r �wait� s
zCondition.waitr c C s� x | j �d�r | j�d�}qW d}x*||k rL| j�d�rL| j�� |d7 }q$W |r�xt|�D ]}| j �� q\W x| j�d�r~qpW d S )NFr r )rU r- rT rV r. r )r$ �nZresZsleepersr) r r r �notify s
zCondition.notifyc C s | j tjd� d S )N)rZ )r[ r �maxsize)r$ r r r �
notify_all( s zCondition.notify_allc C sh |� }|r|S |d k r$t �� | }nd }d }x6|sb|d k rP|t �� }|dkrPP | �|� |� }q.W |S )Nr )�timeZ monotonicrY )r$ Z predicaterX �resultZendtimeZwaittimer r r �wait_for+ s
zCondition.wait_for)N)N)r )N)r: r; r< r+ r4 r6 r/ r0 r rF rY r[ r] r` r r r r r � s
c @ s6 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
d �Zd S )
r c C s |� |�� �| _|�d�| _d S )Nr )r r �_condr �_flag)r$ r( r r r r+ C s zEvent.__init__c C s0 | j � | j�d�r"| j�� dS dS Q R X d S )NFT)ra rb r- r. )r$ r r r �is_setG s
z Event.is_setc C s6 | j �& | j�d� | j�� | j �� W d Q R X d S )NF)ra rb r- r. r] )r$ r r r �setN s
z Event.setc C s" | j � | j�d� W d Q R X d S )NF)ra rb r- )r$ r r r �clearT s z Event.clearNc C sT | j �D | j�d�r | j�� n | j �|� | j�d�rF| j�� dS dS Q R X d S )NFT)ra rb r- r. rY )r$ rX r r r rY X s
z
Event.wait)N)r: r; r< r+ rc rd re rY r r r r r A s
c @ sZ e Zd Zddd�Zdd� Zdd� Zedd � �Zejd
d � �Zed d � �Z e jd
d � �Z dS )�BarrierNc C sR dd l }ddlm} ||�d�d �}|�� }| �|||||f� d| _d| _d S )Nr r )�
BufferWrapperr) r )�struct�heaprg �calcsizer r6 �_staterO ) r$ Zparties�actionrX r( rh rg �wrapperZcondr r r r+ j s zBarrier.__init__c C s. |\| _ | _| _| _| _| j�� �d�| _d S )Nr) )�_parties�_action�_timeoutra �_wrapperZcreate_memoryview�cast�_array)r$ r5 r r r r6 s s zBarrier.__setstate__c C s | j | j| j| j| jfS )N)rn ro rp ra rq )r$ r r r r4 x s zBarrier.__getstate__c C s
| j d S )Nr )rs )r$ r r r rk | s zBarrier._statec C s || j d< d S )Nr )rs )r$ r& r r r rk � s c C s
| j d S )Nr )rs )r$ r r r rO � s zBarrier._countc C s || j d< d S )Nr )rs )r$ r& r r r rO � s )NN)
r: r; r< r+ r6 r4 �propertyrk �setterrO r r r r rf h s
rf )�__all__rM r r= r r^ � r r
r r r
� ImportError�listr rP r? r@ �objectr r r r r r rf r r r r �<module> s. Mo'
........