File: //usr/local/lib/python3.10/test/support/__pycache__/interpreters.cpython-310.opt-2.pyc
o
�i� � @ s� d dl Z d dlZd dlmZmZmZmZ g d�Zdd�dd�Zdd � Z d
d � Z
d d
� Z G dd� d�Z dd� Z
dd� ZG dd� d�Ze� ZG dd� de�ZG dd� de�ZdS )� N)� ChannelError�ChannelNotFoundError�ChannelEmptyError� is_shareable)
� Interpreter� get_current�get_main�create�list_all� SendChannel� RecvChannel�create_channel�list_all_channelsr r r r T��isolatedc C s t j| d�}t|| d�S )Nr )�
_interpretersr r )r �id� r �6/usr/local/lib/python3.10/test/support/interpreters.pyr s r c C � dd� t �� D �S )Nc S s g | ]}t |��qS r )r )�.0r r r r �
<listcomp> s z list_all.<locals>.<listcomp>)r r
r r r r r
s r
c C � t �� } t| �S �N)r r r �r r r r r ! � r c C r r )r r r r r r r r ' r r c @ sj e Zd Z dd�dd�Zdd� Zdd� Zd d
� Zed d � �Zed
d� �Z dd� Z
dd� Z dd�dd�Z dS )r Nr c C s. t |ttjf�std|����|| _|| _d S �Nzid must be an int, got )�
isinstance�intr Z
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�|�� d�S )N)r r c s s" � | ] \}}|� d |��V qdS )�=Nr )r �k�vr r r � <genexpr>8 s � z'Interpreter.__repr__.<locals>.<genexpr>�(z, �))�dictr r r! �items�type�__name__�join)r" �data�kwargsr r r �__repr__6 s zInterpreter.__repr__c C �
t | j�S r ��hashr �r" r r r �__hash__; �
zInterpreter.__hash__c C s t |t�stS |j| jkS r )r r �NotImplementedr �r" �otherr r r �__eq__> s
zInterpreter.__eq__c C � | j S r �r r5 r r r r D � zInterpreter.idc C s | j d u r t�| j�| _ | j S r )r! r Z is_isolatedr r5 r r r r H s
zInterpreter.isolatedc C � t �| j�S r )r �
is_runningr r5 r r r r@ P s zInterpreter.is_runningc C r? r )r Zdestroyr r5 r r r �closeT s zInterpreter.close)�channelsc C s t �| j||� d S r )r Z
run_stringr )r" Zsrc_strrB r r r �run\ s zInterpreter.run)
r- �
__module__� __qualname__r# r1 r6 r; �propertyr r r@ rA rC r r r r r - s
r c C s$ t �� } t| �t| �}}||fS r )r Zchannel_creater r )�cid�recv�sendr r r r
d s r
c C r )Nc S s g | ]
}t |�t|�f�qS r )r r )r rG r r r r p s �z%list_all_channels.<locals>.<listcomp>)r Zchannel_list_allr r r r r n s �r c @ s: e Zd Z dd� Zdd� Zdd� Zdd� Zed d
� �Zd S ) � _ChannelEndc C s( t |ttjf�std|����|| _d S r )r r r Z ChannelIDr r )r" r r r r r# w s
z_ChannelEnd.__init__c C s t | �j� dt| j�� d�S )Nz(id=r) )r, r- r r r5 r r r r1 | s z_ChannelEnd.__repr__c C r2 r r3 r5 r r r r6 r7 z_ChannelEnd.__hash__c C s4 t | t�r
t |t�s tS nt |t�stS |j| jkS r )r r r8 r r r9 r r r r; � s
�
z_ChannelEnd.__eq__c C r< r r= r5 r r r r � r> z_ChannelEnd.idN) r- rD rE r# r1 r6 r; rF r r r r r rJ t s rJ c @ s, e Zd Z e� dd�dd�Zefdd�ZdS )r g{�G�z�?)� _sentinel�_delayc C s< t �| j|�}||u r t�|� t �| j|�}||u s |S r )r � channel_recvr �time�sleep)r" rK rL �objr r r rH � s
�zRecvChannel.recvc C s$ |t u r t�| j�S t�| j|�S r )�_NOT_SETr rM r )r" �defaultr r r � recv_nowait� s zRecvChannel.recv_nowaitN)r- rD rE �objectrH rQ rS r r r r r � s r c @ s e Zd Z dd� Zdd� ZdS )r c C s t �| j|� t�d� d S )N� )r � channel_sendr rN rO �r" rP r r r rI � s zSendChannel.sendc C s t �| j|�S r )r rV r rW r r r � send_nowait� s zSendChannel.send_nowaitN)r- rD rE rI rX r r r r r � s r )rN Z_xxsubinterpretersr r r r r �__all__r r
r r r r
r rJ rT rQ r r r r r r �<module> s 7