| Server IP : 46.101.140.223 / Your IP : 216.73.217.61 Web Server : nginx/1.22.1 System : Linux debian-s-1vcpu-1gb-fra1-01 6.1.0-49-amd64 #1 SMP PREEMPT_DYNAMIC Debian 6.1.174-1 (2026-05-26) x86_64 User : deploy-others ( 1001) PHP Version : 8.2.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /lib/python3.11/multiprocessing/dummy/__pycache__/ |
Upload File : |
�
�j� � �N � g d �Z ddlZddlZddlZddlZddlmZ ddlmZmZm Z m
Z
ddlm Z m Z m
Z
ddlmZ G d� d ej � � ZeZej Z ej � � e� � _ d
� Zd � Z G d � d
e� � ZeZe Z dd�Z G d� de� � Z d� Z d� Z dd�Z!eZ"dS ))�Process�current_process�active_children�freeze_support�Lock�RLock� Semaphore�BoundedSemaphore� Condition�Event�Barrier�Queue�Manager�Pipe�Pool�
JoinableQueue� N� )r )r r r r )r r
r )r
c �< � e Zd Zddddi fd�Zd� Zed� � � ZdS )� DummyProcessN� c � � t j � | |||||� � d | _ t j � � | _ d| _ t � � | _ d S )NF)
� threading�Thread�__init__�_pid�weakref�WeakKeyDictionary� _children�
_start_calledr �_parent)�self�group�target�name�args�kwargss �5/usr/lib/python3.11/multiprocessing/dummy/__init__.pyr zDummyProcess.__init__$ sS � ���!�!�$��v�t�T�6�J�J�J��� � �2�4�4��� "���&�(�(�� � � � c �, � | j t � � ur4t d� | j t � � � � � � �d| _ t | j d� � rd | j j | < t j � | � � d S )Nz,Parent is {0!r} but current_process is {1!r}Tr )
r r � RuntimeError�formatr �hasattrr r r �start�r! s r' r- zDummyProcess.start+ s� � � �<�� 0� 0� 0� 0� �>�E�E��L�/�"3�"3�5� 5�6� 6�
6� "��� �4�<�� -� -� 0�+/�D�L� "�4� (��� � �t�$�$�$�$�$r( c �@ � | j r| � � � sdS d S )Nr )r �is_aliver. s r' �exitcodezDummyProcess.exitcode5 s& � � � � �d�m�m�o�o� ��1��4r( )�__name__�
__module__� __qualname__r r- �propertyr1 r r( r' r r " s] � � � � � � !�$�T��2� )� )� )� )�%� %� %� �� � �X�� � r( r c � � t � � j } t | � � D ],}|� � � s| � |d � � �-t | � � S �N)r r �listr0 �pop)�children�ps r' r r D sV � � � � �*�H�
�(�^�^� "� "���z�z�|�|� "� �L�L��D� !� !� !�� ��>�>�r( c � � d S r7 r r r( r' r r K � � ��Dr( c � � e Zd Zd� Zd� ZdS )� Namespacec �: � | j � |� � d S r7 )�__dict__�update)r! �kwdss r' r zNamespace.__init__S s � � �
� � �T�"�"�"�"�"r( c �2 � t | j � � � � � }g }|D ]4\ }}|� d� � s|� |�d|��� � �5|� � � | j j �dd� |� � �d�S )N�_�=�(�, �)) r8 rA �items�
startswith�append�sort� __class__r2 �join)r! rJ �tempr$ �values r' �__repr__zNamespace.__repr__U s� � ��T�]�(�(�*�*�+�+���� � 5� 5�K�D�%��?�?�3�'�'�
5�� � �t�t�t�U�U� 3�4�4�4�� � � � � � � �>�2�2�2�D�I�I�d�O�O�O�O�D�Dr( N)r2 r3 r4 r rR r r( r' r? r? R s7 � � � � � �#� #� #�E� E� E� E� Er( r? Tc �, � t j | |� � S r7 )�array)�typecode�sequence�locks r' �ArrayrX a s � � �;�x�� *� *�*r( c �R � e Zd Zdd�Zed� � � Zej d� � � Zd� ZdS )�ValueTc �" � || _ || _ d S r7 )� _typecode�_value)r! rU rQ rW s r' r zValue.__init__e s � �!����� � � r( c � � | j S r7 �r] r. s r' rQ z Value.valuei s
� ��{�r( c � � || _ d S r7 r_ )r! rQ s r' rQ z Value.valuem s
� ��� � � r( c �R � dt | � � j �d| j �d| j �d�S )N�<rG rH z)>)�typer2 r\ r] r. s r' rR zValue.__repr__q s, � � � #�D�z�z� 2� 2� 2�4�>�>�>�$�+�+�+�N�Nr( N�T)r2 r3 r4 r r5 rQ �setterrR r r( r' rZ rZ d st � � � � � � � � � � �� � �X�� �\� � � �\� �O� O� O� O� Or( rZ c �0 � t j t S r7 )�sys�modulesr2 r r( r' r r t s � � �;�x� � r( c � � d S r7 r r r( r' �shutdownrj w r= r( r c �( � ddl m} || ||� � S )N� )�
ThreadPool)�poolrm )� processes� initializer�initargsrm s r' r r z s( � �!�!�!�!�!�!� �:�i��h� 7� 7�7r( rd )NNr )#�__all__r rg r rT �
connectionr r r r r r r
r �queuer
r r r �current_threadr r r r r �objectr? �dictr8 rX rZ r rj r r r r( r' �<module>rx s� �� � � �� � � � �
�
�
�
� ���� � � � � � � � � � � >� >� >� >� >� >� >� >� >� >� >� >� /� /� /� /� /� /� /� /� /� /� � � � � � � � � � � �9�#� � � �< ���*�� 7�g� 7� 9� 9��� � � �� � � � � �
E�
E�
E�
E�
E��
E�
E�
E� �� ��+� +� +� +�O� O� O� O� O�F� O� O� O� !� !� !� � � �8� 8� 8� 8� �
�
�
r(