python (3.12.0)
Browse
Usage
Versions
ˑe2J ^ d Z ddlZddlZddlmZ ddlmZ G d d Z G d d eej Z G d
d ej Z G d d
eej Z
G d deej Z G d de Z G d dej Z G d dej Zy))LockEvent Condition SemaphoreBoundedSemaphoreBarrier N )
exceptions)mixinsc e Zd Zd Zd Zy)_ContextManagerMixinc @ K | j d { y 7 wN)acquireselfs A/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/asyncio/locks.py
__aenter__z _ContextManagerMixin.__aenter__
s lln s c , K | j y wr )release)r exc_typeexctbs r __aexit__z _ContextManagerMixin.__aexit__ s s N)__name__
__module__ __qualname__r r r r
r
s r r
c > e Zd Z d Z fdZd Zd Zd Zd Z xZ S )r c d | _ d| _ y NF)_waiters_lockedr s r __init__z
Lock.__init__M s
r c t | }| j rdnd}| j r| dt | j }d|dd d| dS Nlockedunlocked
, waiters:<r []>)super__repr__r$ r# lenr resextra __class__s r r0 z
Lock.__repr__Q sY g LLj == gZDMM(:';<E3q9+Rwb))r c | j S r )r$ r s r r( z Lock.lockedX s .||r c L K | j s0| j t d | j D rd| _ y| j t j | _ | j j
}| j j | | d { | j j | d| _ y7 (# | j j | w xY w# t j $ r | j s| j w xY ww)Nc 3 < K | ] }|j y wr cancelled.0ws r <genexpr>z Lock.acquire.<locals>.<genexpr>c s 9aAKKM9s T) r$ r# all collectionsdeque _get_loop
create_futureappendremover
CancelledError_wake_up_firstr futs r r z Lock.acquire\ s
$--"794==99 DL == ' - - /DMnn ,,.
S!
*
$$S)
$$S)(( <<##% sB B D$ C %C&C *C0 D$C C--C0 01D!!D$c b | j rd| _ | j y t d )NFzLock is not acquired.)r$ rG RuntimeErrorr s r r z Lock.release| s/ << DL ! 67 7r c | j sy t t | j }|j s|j d y y # t $ r Y y w xY wNT)r# nextiter
StopIterationdone
set_resultrH s r rG zLock._wake_up_first sW 8}} tDMM*+C xxz NN4
s A A A )
r r r r% r0 r( r r rG
__classcell__r5 s @r r r s( 3j * @8"
!r r c > e Zd Z d Z fdZd Zd Zd Zd Z xZ S )r c D t j | _ d| _ y r" )r@ rA r# _valuer s r r% zEvent.__init__ s #))+
r c t | }| j rdnd}| j r| dt | j }d|dd d| dS ) Nsetunsetr* r+ r r, r- r. )r/ r0 rW r# r1 r2 s r r0 zEvent.__repr__ sY g ' == gZDMM(:';<E3q9+Rwb))r c | j S r rW r s r is_setz Event.is_set s C{{r c | j s;d| _ | j D ]$ }|j r|j d & y y rM )rW r# rQ rR rH s r rY z Event.set sD {{ DK}}
)xxzNN4(
) r c d| _ y r" r\ r s r clearz Event.clear s r c , K | j ry| j j }| j j | | d { | j j | y7 !# | j j | w xY wwrM )rW rB rC r# rD rE rH s r waitz
Event.wait sy ;;nn ,,.
S! &II MM %
MM %s0 AB A4 A2A4 B2A4 4 BB)
r r r r% r0 r] rY r` rb rS rT s @r r r s& *
) &r r c B e Zd Z ddZ fdZd Zd ZddZd Z xZ S ) r c |
t }|| _ |j | _ |j | _ |j | _ t j | _ y r )r _lockr( r r r@ rA r# )r locks r r% zCondition.__init__ sF <6D
kk || || #))+
r c t | }| j rdnd}| j r| dt | j }d|dd d| dS r' )r/ r0 r( r# r1 r2 s r r0 zCondition.__repr__ s[ g KKMz == gZDMM(:';<E3q9+Rwb))r c K | j s t d | j | j j }| j
j
| | d { | j
j | d} | j d { |rt j y7 P7 # t j $ r d}Y nw xY wM# | j
j | w xY w# d} | j d { 7 n # t j $ r d}Y nw xY w7|rt j w xY ww)Nz cannot wait on un-acquired lockFT) r( rK r rB rC r# rD rE r r
rF )r rI r: s r rb zCondition.wait sE {{} @A A 0.."002C MM %
*
$$S) I% ,,.(( /// )!00 % $I%
$$S) I% ,,.((!00 % $I% /// s -E9D *C /C 0C 5D EC 'C(C ,E C C C EC E C==D ED DD E D74E6D77EEc j K | }|s"| j d { | }|s"|S 7 wr rb )r predicateresults r wait_forzCondition.wait_for s> ))+ [F
s 31
33c | j s t d d}| j D ]0 }||k\ r y |j r|dz
}|j d 2 y )Nz!cannot notify on un-acquired lockr r F)r( rK r# rQ rR )r nidxrI s r notifyzCondition.notify) s^
{{} BC C== &Cax88:qu%
&r c N | j t | j y r )rq r1 r# r s r
notify_allzCondition.notify_allA s
C
&'r r r )
r r r r% r0 rb rm rq rs rS rT s @r r r s'
,*#0J &0(r r c @ e Zd Z ddZ fdZd Zd Zd Zd Z xZ S )r c @ |dk r t d d | _ || _ y )Nr z$Semaphore initial value must be >= 0)
ValueErrorr# rW )r values r r% zSemaphore.__init__Y s# 19 CD D
r c t | }| j rdnd| j }| j r| dt | j }d|dd d| dS ) Nr( zunlocked, value:r* r+ r r, r- r. )r/ r0 r( rW r# r1 r2 s r r0 zSemaphore.__repr___ sg g KKM1A$++ /O == gZDMM(:';<E3q9+Rwb))r c f | j dk( xs t d | j xs dD S )Nr c 3 > K | ] }|j y wr r9 r; s r r> z#Semaphore.locked.<locals>.<genexpr>i s AaAKKM!As r )rW anyr# r s r r( zSemaphore.lockedf s4 G{{a C ADMM,?RA A Cr c K | j s| xj dz c_ y| j t j | _ | j j
}| j j | | d { | j j | | j dkD r| j y7 @# | j j | w xY w# t j $ r7 |j s%| xj dz
c_ | j w xY ww)Nr Tr )
r( rW r# r@ rA rB rC rD rE r
rF r:
_wake_up_nextrH s r r zSemaphore.acquirek s {{} KK1 K == ' - - /DMnn ,,.
S!
*
$$S) ;;?
$$S)(( ==? q ""$ sC BD?
C CC C2 /!D?C C//C2 2A
D<<D?c P | xj dz
c_ | j y Nr )rW r~ r s r r zSemaphore.release s#
q r c | j sy | j D ]: }|j r| xj dz c_ |j d y y )Nr T)r# rQ rW rR rH s r r~ zSemaphore._wake_up_next sH 7}} == C88: q t$ r rt )
r r r r% r0 r( r r r~ rS rT s @r r r J s( *C
"H r r c , e Zd Z d fd Z fdZ xZS )r c 2 || _ t | | y r ) _bound_valuer/ r% )r rx r5 s r r% zBoundedSemaphore.__init__ s !
r c j | j | j k\ r t d t | y )Nz(BoundedSemaphore released too many times)rW r rw r/ r )r r5 s r r zBoundedSemaphore.release s+ ;;$++ + GH H
r rt )r r r r% r rS rT s @r r r s r r c e Zd ZdZdZdZdZy)
_BarrierStatefillingdraining resettingbrokenN)r r r FILLINGDRAINING RESETTINGBROKENr r r r r s GHI
Fr r c e Zd Z d Z fdZd Zd Zd Zd Zd Z d Z
d Z d
Z d Z
ed Zed
Zed Z xZS )r c |dk r t d t | _ || _ t j
| _ d| _ y )Nr zparties must be > 0r )rw r _cond_partiesr r _state_count)r partiess r r% zBarrier.__init__ s< ? Q; 23 3 [
#++ r c t | }| j j }| j s |d| j
d| j z
}d|dd d| dS )Nr* /r+ r r, r- r. )r/ r0 r rx r n_waitingr r2 s r r0 zBarrier.__repr__ sd g ;;$$%{{ z$..!14<<.A AE3q9+Rwb))r c > K | j d { S 7 wr rj r s r r zBarrier.__aenter__ s YY[ s c K y wr r )r argss r r zBarrier.__aexit__ s s c 2 K | j 4 d { | j d { | j }| xj dz
c_ |dz | j k( r| j d { n| j d { || xj dz c_ | j
cd d d d { S 7 7 7 Y7 B7
# | xj dz c_ | j
w xY w# 1 d { 7 sw Y y xY wwr )r _blockr r _release_wait_exit)r indexs r rb z Barrier.wait s :: ++-
q 19
- --/)) **,&& q
*& q
s DCDDCDAC8C9CCC%D< DC DDCCD'C??DDD DDc K j j fd d { j t j u rt j d y 7 6w)Nc \ j t j t j fvS r )r r r r r s r <lambda>z Barrier._block.<locals>.<lambda> s& DKK &&
(?(?( r zBarrier aborted)r rm r r r r
BrokenBarrierErrorr s `r r zBarrier._block sZ jj!!
;;-.. . //0AB B /
s "A A 7A c j K t j | _ | j j y wr )r r r r rs r s r r zBarrier._release s%
$,,
s 13c K j j fd d { j t j t j
fv rt
j d y 7 Fw)Nc < j t j uS r )r r r r s r r z Barrier._wait.<locals>.<lambda> s $++]=R=R*R r zAbort or reset of barrier)r rm r r r r r
r r s `r r z
Barrier._wait s] jj!!"RSSS ;;=// 1H1HI I //0KL L J Ts "A.A,AA.c | j dk( r\| j t j t j fv rt j
| _ | j j y y Nr )r r r r r r r rs r s r r z
Barrier._exit sO ;;! {{} 6 6
8N8N OO + 3 3 JJ ! ! # r c j K | j 4 d { | j dkD r2| j t j ur+t j | _ nt j
| _ | j j
d d d d { y 7 7 # 1 d { 7 sw Y y xY wwr )r r r r r r rs r s r resetz
Barrier.reset" s
:: $ ${{Q;;m&=&=="/"9"9DK + 3 3 JJ ! ! # $ $ $ $ $ $ $sE B3BB3A1B B3B B3 B3 B0$B' %B0,B3c K | j 4 d { t j | _ | j j d d d d { y 7 D7 # 1 d { 7 sw Y y xY wwr )r r r r rs r s r abortz
Barrier.abort1 s`
:: $ $'..DK JJ ! ! # $ $ $ $ $ $ $sD A2AA20A A2AA2A2 A/#A& $A/+A2c | j S r )r r s r r zBarrier.parties; s F}} r c V | j t j u r | j S yr )r r r r r s r r zBarrier.n_waiting@ s$ J ;;-// /;; r c < | j t j u S r )r r r r s r r zBarrier.brokenG s >{{m 2 222r )r r r r% r0 r r rb r r r r r r propertyr r r rS rT s @r r r s} *!
.C M$
$ $ 3 3r r )__all__r@ enum r
r r
_LoopBoundMixinr r r r r Enumr r r r r <module>r s ! * C! !7!7 C!L:&F " " :&zm($f&<&< m(`W$f&<&< Wty $DII M3f$$ M3r