/usr/lib/python3.10/multiprocessing/__pycache__
Edit: /usr/lib/python3.10/multiprocessing/__pycache__/synchronize.cpython-310.pyc (11327B)
o
9jZ- @ s g d Z ddlZddlZddlZddlZddlZddlmZ ddlmZ ddlm Z z
ddlm
Z
m Z W n e y? e dw e
ed \ZZej
jZG d
d d eZ
G d d
d
e
ZG dd deZG dd de
ZG dd de
ZG dd deZG dd deZG dd dejZdS ))LockRLock SemaphoreBoundedSemaphore ConditionEvent N )context)process)util)SemLock
sem_unlinkzThis 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}tdD ] }zt|||| | }| _
W n t y5 Y qw nt dt
d|j | tjdkrWdd } t | | | j
jd urydd lm}
|
| j
jd
t j| tj| j
jfd d d S d S )
Nwin32forkd z cannot find name for semaphorez created semlock with handle %sc S s | j d S N)_semlock _after_fork)obj r 2/usr/lib/python3.10/multiprocessing/synchronize.pyr G s z%SemLock.__init__.
._after_forkr )register semaphorer ) exitpriority)r _default_context get_contextget_start_methodsysplatformrange_multiprocessingr
_make_namer FileExistsErrorr debughandle
_make_methodsregister_after_forknameresource_trackerr Finalize_cleanup) selfkindvaluemaxvaluectxr(
unlink_nowislr r r r r __init__2 s6
zSemLock.__init__c C s" ddl m} t| || d d S )Nr )
unregisterr )r) r5 r
)r( r5 r r r r+ T s zSemLock._cleanupc C | j j| _| j j| _d S r )r acquirereleaser, r r r r& Z
zSemLock._make_methodsc C
| j S r )r __enter__r9 r r r r< ^
zSemLock.__enter__c G | j j| S r )r __exit__r, argsr r r r? a zSemLock.__exit__c C sD t | | j}tjdkrt |j}n|j}||j|j |j
fS )Nr ) r assert_spawningr r r get_spawning_popenduplicate_for_childr% r- r/ r( )r, r3 hr r r __getstate__d s
zSemLock.__getstate__c C s, t jj| | _td|d | d S )Nz recreated blocker with handle %rr )r! r _rebuildr r r$ r& r, stater r r __setstate__m s zSemLock.__setstate__c C s dt jd ttjf S )Nz%s-%s semprefix)r
current_process_confignextr _randr r r r r" r s zSemLock._make_nameN)__name__
__module__ __qualname__tempfile_RandomNameSequencerP r4 staticmethodr+ r& r< r? rG rK r" r r r r r . s "
r c @ s& e Zd Zd ddZdd Zdd ZdS )
r r c C s t j| t|t|d d S Nr0 )r r4 SEMAPHORE
SEM_VALUE_MAXr, r. r0 r r r r4 } zSemaphore.__init__c C r; r )r
_get_valuer9 r r r get_value r= zSemaphore.get_valuec C s6 z| j }W n ty d}Y nw d| jj|f S )Nunknownz<%s(value=%s)>)r r] Exception __class__rQ r, r. r r r __repr__ s zSemaphore.__repr__Nr )rQ rR rS r4 r^ rc r r r r r { s
r c @ s e Zd ZdddZdd ZdS )r r c C s t j| t|||d d S rW r r4 rY r[ r r r r4 r\ zBoundedSemaphore.__init__c C s< z| j }W n ty d}Y nw d| jj|| j jf S )Nr_ z<%s(value=%s, maxvalue=%s)>)r r] r` ra rQ r/ rb r r r rc s zBoundedSemaphore.__repr__Nrd rQ rR rS r4 rc r r r r r s
r c @ e Zd Zdd Zdd ZdS )r c C t j| tdd|d d S Nr rX re r, r0 r r r r4 r\ 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 SomeOtherThreadSomeOtherProcessr_ z<%s(owner=%s)>) r _is_miner
rM r( threadingcurrent_threadr] _countr` ra rQ )r, r( r r r rc s
z
Lock.__repr__Nrf r r r r r r c @ rg )r c C rh ri )r r4 RECURSIVE_MUTEXrj r r r r4 r\ 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 )
Nrk rl r )rm r r )rn nonzero)ro rv )r_ r_ <%s(%s, %s)>) r rp r
rM r( rq rr rs r] r` ra rQ )r, r( countr r r rc s
zRLock.__repr__Nrf r r r r r rt r c @ sl e Zd ZdddZdd Zdd Zdd Zd
d Zd d
Zdd Z dddZ
dddZ dd Z dddZ
dS )r Nc C s> |p| | _|d| _|d| _|d| _| d S Nr )r _lockr _sleeping_count _woken_count_wait_semaphorer& )r, lockr0 r r r r4 s
zCondition.__init__c C s t | | j| j| j| jfS r )r rC rz r{ r| r} r9 r r r rG s
zCondition.__getstate__c C s |\| _ | _| _| _| d S r )rz r{ r| r} r& rI r r r rK s
zCondition.__setstate__c C r; r )rz r< r9 r r r r< r= zCondition.__enter__c G r> r )rz r? r@ r r r r? rB zCondition.__exit__c C r6 r )rz r7 r8 r9 r r r r& r: zCondition._make_methodsc C sH z| j j | jj }W n ty d}Y nw d| jj| j|f S )Nr_ rw )r{ r r] r| r` ra rQ rz )r, num_waitersr r r rc s
zCondition.__repr__c C s | j j s
J d| j | j j }t|D ]}| j qz| jd|W | j t|D ]}| j q2S | j t|D ]}| j qDw )Nz,must acquire() condition before using wait()T)
rz r rp r{ r8 rs r r} r7 r| )r, timeoutrx r2 r r r wait s"
zCondition.waitr c C s | j j s
J d| jdrJ d| jdr,| jd}|s&J d| jdsd}||k rK| jdrK| j |d7 }||k rK| jds8|rht|D ]}| j qQ| jdrj | jds_d S d S d S )Nzlock is not ownedFznotify: Bug in sleeping_count.acquire- res should not be Falser r ) rz r rp r} r7 r| r{ r8 r )r, nressleepersr2 r r r notify s.
zCondition.notifyc C s | j tjd d S )N)r )r r maxsizer9 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 ry )time monotonicr )r, predicater resultendtimewaittimer r r wait_for+ s"
zCondition.wait_forr rd )rQ rR rS r4 rG rK r< r? r& rc r r r 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 ry )r r _condr _flagrj r r r r4 C s zEvent.__init__c C sV | j | jdr| j W d dS W d dS 1 s$w Y d S NFT)r r r7 r8 r9 r r r is_setG s
$z Event.is_setc C sL | j | jd | j | j W d d S 1 s w Y d S NF)r r r7 r8 r r9 r r r setN s
"z Event.setc C s8 | j | jd W d d S 1 sw Y d S r )r r r7 r9 r r r clearT s "z Event.clearNc C sz | j 0 | jdr| j n| j | | jdr*| j W d dS W d dS 1 s6w Y d S r )r r r7 r8 r )r, r r r r r X s
$z
Event.waitr )rQ rR rS r4 r r r r r r r r r A s r c @ sZ e Zd ZdddZdd Zdd Zedd Zejd
d Zed d Z e jd
d Z dS )BarrierNc C sR dd l }ddlm} ||dd }| }| |||||f d| _d| _d S )Nr r )
BufferWrapperr2 r )structheapr calcsizer rK _staters ) r, partiesactionr r0 r r wrappercondr r r r4 j s
zBarrier.__init__c C s. |\| _ | _| _| _| _| j d| _d S )Nr2 )_parties_action_timeoutr _wrappercreate_memoryviewcast_arrayrI r r r rK s s zBarrier.__setstate__c C s | j | j| j| j| jfS r )r r r r r r9 r r r rG x s zBarrier.__getstate__c C
| j d S ry r r9 r r r r |
zBarrier._statec C || j d< d S ry r rb r r r r c C r Nr r r9 r r r rs r zBarrier._countc C r r r rb r r r rs r )NN)
rQ rR rS r4 rK rG propertyr setterrs r r r r r h s
r )__all__rq r rT r! r r r
r r r
ImportErrorlistr ru rY rZ objectr r r r r r r r r r r s0
Mo'