/snap/core22/2411/usr/lib/python3.10/test/support/__pycache__
Edit: /snap/core22/2411/usr/lib/python3.10/test/support/__pycache__/interpreters.cpython-310.pyc (7104B)
o
`wi @ s d Z ddlZddlZddlmZmZmZmZ g dZddddZ d d
Z
d d Z d
d Z G dd dZ
dd Zdd ZG dd dZe ZG dd deZG dd deZdS )z"Subinterpreters High Level Module. N) ChannelErrorChannelNotFoundErrorChannelEmptyError is_shareable)
Interpreter get_currentget_maincreatelist_all SendChannel RecvChannelcreate_channellist_all_channelsr r r r Tisolatedc C s t j| d}t|| dS )z'Return a new (idle) Python interpreter.r )
_interpretersr r )r id r 0/usr/lib/python3.10/test/support/interpreters.pyr s r c C dd t D S )z!Return all existing interpreters.c S s g | ]}t |qS r )r ).0r r r r
s z list_all..)r r
r r r r r
s r
c C t } t| S )z)Return the currently running interpreter.)r r r r r r r r ! r c C r )z Return the main interpreter.)r r r r r r r r ' r r c @ sl e Zd ZdZddddZdd Zdd Zd
d Zed d
Z edd Z
dd Z dd Z ddddZ
dS )r z A single Python interpreter.Nr c C s. t |ttjfstd||| _|| _d S Nzid must be an int, got )
isinstanceintr
InterpreterID TypeError_id _isolated)selfr r r r r __init__0 s
zInterpreter.__init__c C sB t t| j| jd}dd | D }t| j dd| dS )N)r r c s s" | ] \}}| d |V qdS )=Nr )r kvr r r 8 s z'Interpreter.__repr__..(z, ))dictr r r! itemstype__name__join)r" datakwargsr r r __repr__6 s zInterpreter.__repr__c C
t | jS Nhashr r" r r r __hash__;
zInterpreter.__hash__c C s t |tstS |j| jkS r3 )r r NotImplementedr r" otherr r r __eq__> s
zInterpreter.__eq__c C | j S r3 r r6 r r r r D zInterpreter.idc C s | j d u r t| j| _ | j S r3 )r! r is_isolatedr r6 r r r r H s
zInterpreter.isolatedc C t | jS )z.)r channel_list_allr r r r r n s r c @ s< e Zd ZdZdd Zdd Zdd Zdd Zed
d Z d S )
_ChannelEndz/The base class for RecvChannel and SendChannel.c C s( t |ttjfstd||| _d S r )r r r ChannelIDr r )r" r r r r r# w s
z_ChannelEnd.__init__c C s t | j dt| j dS )Nz(id=r) )r, r- r r r6 r r r r1 | s z_ChannelEnd.__repr__c C r2 r3 r4 r6 r r r r7 r8 z_ChannelEnd.__hash__c C s4 t | tr
t |ts tS nt |tstS |j| jkS r3 )r r r9 r r r: r r r r< s
z_ChannelEnd.__eq__c C r= r3 r> r6 r r r r r? z_ChannelEnd.idN)
r- rI rJ rK r# r1 r7 r< rL r r r r r rR t s rR c @ s. e Zd ZdZe ddddZefddZdS ) r z1The receiving end of a cross-interpreter channel.g{Gz?) _sentinel_delayc C s: t | j|}||u rt| t | j|}||u s |S )zReturn the next object from the channel.
This blocks until an object has been sent, if none have been
sent already.
)r channel_recvr timesleep)r" rT rU objr r r rO s
zRecvChannel.recvc C s" |t u r
t| jS t| j|S )zReturn the next object from the channel.
If none have been sent then return the default if one
is provided or fail with ChannelEmptyError. Otherwise this
is the same as recv().
)_NOT_SETr rV r )r" defaultr r r recv_nowait s zRecvChannel.recv_nowaitN)r- rI rJ rK objectrO rZ r\ r r r r r s r c @ s e Zd ZdZdd Zdd ZdS )r z/The sending end of a cross-interpreter channel.c C s t | j| td dS )z{Send the object (i.e. its data) to the channel's receiving end.
This blocks until the object is received.
N)r channel_sendr rW rX r" rY r r r rP s zSendChannel.sendc C s t | j|S )zSend the object to the channel's receiving end.
If the object is immediately received then return True
(else False). Otherwise this is the same as send().
)r r_ r r` r r r send_nowait s zSendChannel.send_nowaitN)r- rI rJ rK rP ra r r r r r s r )rK rW _xxsubinterpretersr r r r r __all__r r
r r r r
r rR r] rZ r r r r r r s 7