Uname : Linux premium36.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64
Soft : LiteSpeed
Ip : 198.54.115.237
Port : 443
~
/
opt
/
alt
/
python310
/
lib64
/
python3.10
/
multiprocessing
/
__pycache__
[ HOME ]
Exec
Submit
queues.cpython-310.opt-1.pyc
o �=?h�. � @ s� g d �Z ddlZddlZddlZddlZddlZddlZddlZddlZddl m Z mZ ddlZddl mZ ddl mZ ejjZddlmZmZmZmZmZ G dd � d e�Ze� ZG d d� de�ZG dd � d e�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�Zd/dd�Z dd� Z dd� Zdd� Zdd� Z dd� Zdd� Zdd � Zd!d"� Zd#d$� Zed%d&� �Zed'd(� �Zed)d*� �Zed+d,� �ZdS )0r r c C s� |dkr ddl m} || _tjdd�\| _| _|�� | _t � � | _tj dkr*d | _n|�� | _|�|�| _d| _| �� tj dkrIt| tj� d S 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�_resetr r �_after_fork��self�maxsize�ctx� r&