← Back
Editing: synchronize.cpython-310.pyc
o 0�iZ- � @ s g d �Z ddlZddlZddlZddlZddlZddlmZ ddlmZ ddlm Z z ddlm Z m Z W n e y? e d��w e ed ��\ZZej jZG d d � d e�Z G d d � d e �ZG dd� de�ZG dd� de �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 u r t j�� }|�� }tjdkp|dk}td�D ] }zt�|||| � � |� }| _ W n t y5 Y qw nt d��t � d|j � | �� tjdkrWdd� } t �| | � | j jd urydd lm} | | j jd � t j| tj| j jfd d � d S 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 �B/opt/alt/python310/lib64/python3.10/multiprocessing/synchronize.pyr G s z%SemLock.__init__.<locals>._after_forkr )�register� semaphorer )Z exitpriority)r Z_default_contextZ get_contextZget_start_method�sys�platform�range�_multiprocessingr � _make_namer �FileExistsErrorr �debug�handle� _make_methodsZregister_after_fork�name�resource_trackerr ZFinalize�_cleanup) �self�kind�value�maxvalue�ctxr# Z unlink_now�i�slr r r r r �__init__2 s6 � � ��zSemLock.__init__c C s" ddl m} t| � || d� d S )Nr )� unregisterr )r$ r. r )r# r. r r r r% T s zSemLock._cleanupc C � | j j| _| j j| _d S r )r �acquire�release�r& r r r r" Z � zSemLock._make_methodsc C � | j �� S r )r � __enter__r2 r r r r5 ^ � zSemLock.__enter__c G � | j j|� S r )r �__exit__�r& �argsr r r r8 a � zSemLock.__exit__c C sD t �| � | j}tjdkrt �� �|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_RandomNameSequencerD r- � staticmethodr% r" r5 r8 r> rA 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- } � zSemaphore.__init__c C r4 r )r � _get_valuer2 r r r � get_value� r6 zSemaphore.get_valuec C s6 z| j �� }W n ty d}Y nw d| jj|f S )N�unknownz<%s(value=%s)>)r rP � Exception� __class__rE �r& r( r r r �__repr__� s �zSemaphore.__repr__N�r )rE rF rG r- rQ rV r r r r r { s r c @ s e Zd Zddd�Zdd� ZdS )r r c C s t j| t|||d� d S rJ �r r- rL rN r r r r- � rO zBoundedSemaphore.__init__c C s< z| j �� }W n ty d}Y nw d| jj|| j jf S )NrR z<%s(value=%s, maxvalue=%s)>)r rP rS rT rE r) rU r r r rV � s ��zBoundedSemaphore.__repr__NrW �rE rF rG r- rV r r r r r � s r c @ � e Zd Zdd� Zdd� ZdS )r c C � t j| tdd|d� d S �Nr rK rX �r& r* r r r r- � rO z Lock.__init__c C s� z3| j �� r t�� j}t�� jdkr|dt�� j 7 }n| j �� dkr&d}n | j �� dkr0d}nd}W n t y> d}Y nw d | j j |f S ) N� MainThread�|r �Noner �SomeOtherThread�SomeOtherProcessrR z<%s(owner=%s)>) r �_is_miner rB r# � threading�current_threadrP �_countrS rT rE )r& r# r r r rV � s �� �z Lock.__repr__NrY r r r r r � � r c @ rZ )r c C r[ r\ )r r- �RECURSIVE_MUTEXr] r r r r- � rO zRLock.__init__c C s� z>| j �� r!t�� j}t�� jdkr|dt�� j 7 }| j �� }n | j �� dkr-d\}}n| j �� dkr9d\}}nd\}}W n t yK d\}}Y nw d | j j ||f S ) Nr^ r_ r )r` r r )ra �nonzero)rb ri )rR rR � <%s(%s, %s)>) r rc r rB r# rd re rf rP rS rT rE )r& r# �countr r r rV � s � �zRLock.__repr__NrY r r r r r � rg r c @ sl e Zd Zddd�Zdd� Zdd� Zdd � Zd d � Zd d � Zdd� Z ddd�Z ddd�Z dd� Z ddd�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 r )r r< rm rn ro rp r2 r r r r> � s �zCondition.__getstate__c C s |\| _ | _| _| _| �� d S r )rm rn ro rp r" r? r r r rA � s � zCondition.__setstate__c C r4 r )rm r5 r2 r r r r5 � r6 zCondition.__enter__c G r7 r )rm r8 r9 r r r r8 � r; zCondition.__exit__c C r/ r )rm r0 r1 r2 r r r r" � r3 zCondition._make_methodsc C sH z| j j�� | jj�� }W n ty d}Y nw d| jj| j|f S )NrR rj )rn r rP ro rS rT rE rm )r& Z num_waitersr r r rV � s � �zCondition.__repr__c C s� | j j�� s J d��| j�� | j j�� }t|�D ]}| j �� qz| j�d|�W | j �� t|�D ]}| j �� q2S | j �� t|�D ]}| j �� qDw )Nz,must acquire() condition before using wait()T) rm r rc rn r1 rf r rp r0 ro )r& �timeoutrk r+ r r r �wait� s" � � � �zCondition.waitr c C s� | j j�� s J d��| j�d�rJ d��| j�d�r,| j�d�}|s&J d��| j�d�sd}||k rK| j�d�rK| j�� |d7 }||k rK| j�d�s8|rht|�D ]}| j�� qQ| j�d�rj | j�d�s_d S d S 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 ) rm r rc rp r0 ro rn r1 r )r& �n�resZsleepersr+ r r r �notify s. �� � � ��zCondition.notifyc C s | j tjd� d S )N)rt )rv r �maxsizer2 r r r � notify_all( s zCondition.notify_allc C sj |� }|r|S |d urt �� | }nd }d }|s3|d ur)|t �� }|dkr) |S | �|� |� }|r|S rl )�time� monotonicrs )r& Z predicaterr �resultZendtimeZwaittimer r r �wait_for+ s" ��zCondition.wait_forr rW )rE rF rG r- r> rA r5 r8 r" rV rs rv rx r| r r r r r � s r c @ s6 e Zd Zdd� Zdd� Zdd� Zdd� Zd d d �Zd S ) r c C s |� |�� �| _|�d�| _d S rl )r r �_condr �_flagr] r r r r- C s zEvent.__init__c C sV | j � | j�d�r| j�� W d � dS W d � dS 1 s$w Y d S �NFT)r} r~ r0 r1 r2 r r r �is_setG s �$�z Event.is_setc C sL | j � | j�d� | j�� | j �� W d � d S 1 s w Y d S �NF)r} r~ r0 r1 rx r2 r r r �setN s "�z Event.setc C s8 | j � | j�d� W d � d S 1 sw Y d S r� )r} r~ r0 r2 r r r �clearT s "�z Event.clearNc C sz | j �0 | j�d�r| j�� n| j �|� | j�d�r*| j�� W d � dS W d � dS 1 s6w Y d S r )r} r~ r0 r1 rs )r& rr r r r rs X s � $�z Event.waitr )rE rF rG r- r� r� r� rs r r r r r A s r 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 )�structZheapr� Zcalcsizer rA �_staterf ) r& Zparties�actionrr r* r� r� �wrapperZcondr r r r- j s zBarrier.__init__c C s. |\| _ | _| _| _| _| j�� �d�| _d S )Nr+ )�_parties�_action�_timeoutr} �_wrapperZcreate_memoryview�cast�_arrayr? r r r rA s s �zBarrier.__setstate__c C s | j | j| j| j| jfS r )r� r� r� r} r� r2 r r r r> x s �zBarrier.__getstate__c C � | j d S rl �r� r2 r r r r� | � zBarrier._statec C � || j d< d S rl r� rU r r r r� � � c C r� �Nr r� r2 r r r rf � r� zBarrier._countc C r� r� r� rU r r r rf � r� )NN) rE rF rG r- rA r> �propertyr� �setterrf r r r r r� h s r� )�__all__rd r rH r ry � r r r r r � ImportError�listr rh rL rM �objectr r r r r r r� r r r r �<module> s0 � Mo'
Save File
Cancel