← Back
Editing: synchronize.cpython-37.pyc
B � fA- � @ 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 s� | j j�� std��| j�� | j j�� }xt|�D ]}| j �� q4W z| j� d|�S | j �� xt|�D ]}| j � � qjW X d S )Nz,must acquire() condition before using wait()T) rS r rL �AssertionErrorrT r. rO r rV r- rU )r$ �timeoutrR r) r r r �wait� s zCondition.waitr c C s� | j j�� std��| j�d�r(td��x(| j�d�rP| j�d�}|s*td��q*W d}x*||k r�| j�d�r�| j�� |d7 }qXW |r�xt |�D ]}| j�� q�W x| j�d�r�q�W d S )Nzlock is not ownedFz;notify: Should not have been able to acquire_wait_semaphorez>notify: Bug in sleeping_count.acquire- res should not be Falser r ) rS r rL rX rV r- rU rT r. r )r$ �nZresZsleepersr) r r r �notify s zCondition.notifyc C s | j tjd� d S )N)r[ )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 monotonicrZ )r$ Z predicaterY �resultZendtimeZwaittimer r r �wait_for+ s zCondition.wait_for)N)N)r )N)r: r; r< r+ r4 r6 r/ r0 r rF rZ r\ r^ ra 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)rb rc 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)rb rc 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)rb rc 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)rb rc r- r. rZ )r$ rY r r r rZ X s z Event.wait)N)r: r; r< r+ rd re rf rZ 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�heaprh Zcalcsizer r6 �_staterO ) r$ Zparties�actionrY r( ri rh �wrapperZcondr r r r+ j s zBarrier.__init__c C s. |\| _ | _| _| _| _| j�� �d�| _d S )Nr) )�_parties�_action�_timeoutrb �_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 rb 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 rg h s rg )�__all__rM r r= r r_ � r r r r r � ImportError�listr rP r? r@ �objectr r r r r r rg r r r r �<module> s. Mo'
Save File
Cancel