Server: appserver-7f0f8755-nginx-15961cad18524ec5a9db05f2a6a7e440
Current directory: /usr/lib/python3.11/multiprocessing/__pycache__
Software: nginx/1.27.5
Shell Command
Create a new file
Upload file
File: queues.cpython-311.pyc
� ��h�. � � � g d �Z ddlZddlZddlZddlZddlZddlZddlZddlZddl m Z mZ ddlZddl mZ ddl mZ ej j ZddlmZmZmZmZmZ G d� d e� � Z e� � Z G d � de� � Z G d� d e� � ZdS ))�Queue�SimpleQueue� JoinableQueue� N)�Empty�Full� )� connection)�context)�debug�info�Finalize�register_after_fork� is_exitingc �� � e Zd Zdd�Zd� Zd� Zd� Zdd�Zdd �Zdd�Z d� Z d � Zd� Zd� Z d� Zd� Zd� Zd� Zd� Zed� � � Zed� � � Zed� � � Zed� � � Zd S )r r c �� � |dk rddl m} || _ t j d�� � \ | _ | _ |� � � | _ t j � � | _ t j dk rd | _ n|� � � | _ |� |� � | _ d| _ | � � � t j dk rt' | t( j � � d S d S )Nr r )� SEM_VALUE_MAXF��duplex�win32)�synchronizer �_maxsizer �Pipe�_reader�_writer�Lock�_rlock�os�getpid�_opid�sys�platform�_wlock�BoundedSemaphore�_sem� _ignore_epipe�_resetr r �_after_fork��self�maxsize�ctxs �-/usr/lib/python3.11/multiprocessing/queues.py�__init__zQueue.__init__% s� � ��a�<�<�=�=�=�=�=�=��� �%/�_�E�%B�%B�%B�"���d�l��h�h�j�j����Y�[�[�� ��<�7�"�"��D�K�K��(�(�*�*�D�K��(�(��1�1�� �"������ � � ��<�7�"�"���e�&7�8�8�8�8�8� #�"� c � � t j | � � | j | j | j | j | j | j | j | j fS �N) r �assert_spawningr% r r r r r" r$ r �r) s r, �__getstate__zQueue.__getstate__9 sB � ����%�%�%��"�D�M�4�<�����T�[�$�)�T�Z�A� Ar. c � � |\ | _ | _ | _ | _ | _ | _ | _ | _ | � � � d S r0 ) r% r r r r r" r$ r r&