Uname : Linux serv1.rebootns.com 5.14.0-570.62.1.el9_6.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Nov 11 10:10:59 EST 2025 x86_64
Soft : LiteSpeed
Ip : 139.99.125.122
Port : 443
~
/
opt
/
alt
/
python38
/
lib64
/
python3.8
/
multiprocessing
/
__pycache__
[ HOME ]
Exec
Submit
queues.cpython-38.opt-2.pyc
U i�f�- � @ s� d ddgZ ddlZddlZddlZddlZddlZddlZddlZddlm Z m Z ddlZddlm Z ddlmZ ejjZdd lmZmZmZmZmZ G d d � d e�Ze� ZG dd� de�ZG dd� de�ZdS ) �Queue�SimpleQueue� JoinableQueue� N)�Empty�Full� )� connection)�context)�debug�info�Finalize�register_after_fork� is_exitingc @ s� e Zd Zd*dd�Zdd� Zdd� Zdd � Zd+dd �Zd,dd�Zdd� Z dd� Z dd� Zdd� Zdd� Z dd� Zdd� Zdd� Zd d!� Zed"d#� �Zed$d%� �Zed&d'� �Zed(d)� �ZdS )-r r c C s� |dkrddl m} || _tjdd�\| _| _|�� | _t � � | _tj dkrTd | _n |�� | _|�|�| _d| _| �� tj dkr�t| tj� d S )Nr r )� SEM_VALUE_MAXF�Zduplex�win32)Zsynchronizer �_maxsizer �Pipe�_reader�_writer�Lock�_rlock�os�getpid�_opid�sys�platform�_wlockZBoundedSemaphore�_sem� _ignore_epipe�_after_forkr r ��self�maxsize�ctx� r% �;/opt/alt/python38/lib64/python3.8/multiprocessing/queues.py�__init__$ s zQueue.__init__c C s. t �| � | j| j| j| j| j| j| j| j fS �N) r �assert_spawningr r r r r r r r �r"