python (3.11.7)
e d dl Z d dlZd dlmZmZmZmZ g dZdddZd Z d Z
d Z G d
d Z d Z
d
Z G d d Z e Z G d de Z G d de ZdS ) N) ChannelErrorChannelNotFoundErrorChannelEmptyError is_shareable)
Interpreter get_currentget_maincreatelist_all SendChannel RecvChannelcreate_channellist_all_channelsr r r r Tisolatedc P t j | }t || S )Nr )
_interpretersr
r )r ids M/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/test/support/interpreters.pyr
r
s+ 1 x 0 0 0B rH - - -- c > d t j D S )Nc , g | ]}t | S )r ).0r s r
<listcomp>z list_all.<locals>.<listcomp> s ? ? ?KOO ? ? ?r )r r r r r r r s" + ? ?m&<&>&> ? ? ??r c H t j } t | S N)r r r r s r r r ! s 3 " $ $B r??r c H t j } t | S r )r r r r s r r r ' s & ! !B r??r c r e Zd Z dddZd Zd Zd Zed Zed Z d Z
d
Z dd d Z dS )
r Nr c t |t t j f st d| || _ || _ d S Nzid must be an int, got )
isinstanceintr
InterpreterID TypeError_id _isolated)selfr r s r __init__zInterpreter.__init__0 sE "sM$? @AA > <b < <== =!r c t t | j | j }d | D }t | j dd | dS )N)r r c 3 * K | ]\ }}| d |V dS )=Nr )r kvs r <genexpr>z'Interpreter.__repr__.<locals>.<genexpr>8 s0 8841aQ,,,,888888r (z, ))dictr$ r' r( itemstype__name__join)r) datakwargss r __repr__zInterpreter.__repr__6 se s48}}t~>>>884::<<888t**%<< &(9(9<<<<r c * t | j S r hashr' r) s r __hash__zInterpreter.__hash__; DH~~ r c Z t |t st S |j | j k S r )r# r NotImplementedr' r) others r __eq__zInterpreter.__eq__> s) %-- )! !9( (r c | j S r r' r> s r r zInterpreter.idD xr c Z | j t j | j | _ | j S r )r( r is_isolatedr' r> s r r zInterpreter.isolatedH s( > ! + 6tx @ @DN~ r c 6 t j | j S r )r
is_runningr' r> s r rL zInterpreter.is_runningP s J '111r c 6 t j | j S r )r destroyr' r> s r closezInterpreter.closeT s
$TX...r )channelsc > t j | j || d S r )r
run_stringr' )r) src_strrP s r runzInterpreter.run\ s& 7H=====r )
r6
__module__ __qualname__r* r: r? rE propertyr r rL rO rT r r r r r - s &'+ " " " " " = = =
) ) ) X X 2 2 2/ / / +/ > > > > > > >r r c n t j } t | t | }}||fS r )r channel_creater
r )cidrecvsends r r r d s:
&
(
(C S!!;s#3#3$D :r c > d t j D S )Nc J g | ] }t | t | f!S r )r
r )r rZ s r r z%list_all_channels.<locals>.<listcomp>p s= 9 9 9
{3 / / 0 9 9 9r )r channel_list_allr r r r r n s/ > 9 9$577 9 9 9 9r c > e Zd Z d Zd Zd Zd Zed ZdS ) _ChannelEndc z t |t t j f st d| || _ d S r" )r# r$ r ChannelIDr& r' )r) r s r r* z_ChannelEnd.__init__w s> "sM$; <== > <b < <== =r c Z t | j dt | j dS )Nz(id=r2 )r5 r6 r$ r' r> s r r: z_ChannelEnd.__repr__| s* t**%;;3tx==;;;;r c * t | j S r r< r> s r r? z_ChannelEnd.__hash__ r@ r c t | t r t |t st S n t |t st S |j | j k S r )r# r
rB r r' rC s r rE z_ChannelEnd.__eq__ sX dK ( ( " e[11
&%%
&E;// "! !yDH$$r c | j S r rG r> s r r z_ChannelEnd.id rH r N) r6 rU rV r* r: r? rE rW r r r r ra ra t sn 9
< < < % % % X r ra c 8 e Zd Z e dddZefdZdS )r
g{Gz?) _sentinel_delayc t j | j | }||u r2t j | t j | j | }||u 2|S r )r channel_recvr' timesleep)r) ri rj objs r r[ zRecvChannel.recv s`
(9==Y Jv ,TXyAAC Y
r c | |t u rt j | j S t j | j | S r )_NOT_SETr rl r' )r) defaults r recv_nowaitzRecvChannel.recv_nowait s< h -dh77 7 -dh@@ @r N)r6 rU rV objectr[ rq rs r r r r
r
sZ ; &
#+
A
A
A
A
A
Ar r
c e Zd Z d Zd ZdS )r c d t j | j | t j d d S )N )r channel_sendr' rm rn r) ro s r r\ zSendChannel.send s1 "48S111
1
r c 8 t j | j | S r )r rx r' ry s r send_nowaitzSendChannel.send_nowait s )$(C888r N)r6 rU rV r\ r{ r r r r r s5 9 9 9 9 9 9r r )rm _xxsubinterpretersr r r r r __all__r
r r r r r r ra rt rq r
r r r r <module>r~ s ( * * * * . . . . . @ @ @
4> 4> 4> 4> 4> 4> 4> 4>n 9 9 9 6 688A A A A A+ A A A89 9 9 9 9+ 9 9 9 9 9r 
Browse
Usage
Versions