Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /usr/local/lib/python3.9/site-packages/billiard/dummy/__pycache__/ |
a
��Sh � @ s$ d dl Z d dlZd dlZd dlZd dl mZmZmZmZ d dl mZ d dl m
Z
d dl m Z g d�Z
G dd� de j�Zz
e jZW n ey� e jZY n0 G d d
� d
e�ZeZe jZe�� e� _d d � Zd
d� ZG dd� de�Ze Z e Z d dd�Z G dd� de�Z dd� Z dd� Z!d dd �Z"e
Z#dS ) � N)�Lock�RLock� Semaphore�BoundedSemaphore)�Event)�Queue)�Pipe)�Process�current_process�active_children�freeze_supportr r r r � Conditionr r �Managerr �Pool�
JoinableQueuec @ s4 e Zd Zddddi fdd�Zdd� Zedd� �ZdS ) � DummyProcessN� c C s8 t j�| |||||� d | _t�� | _d| _t� | _ d S )NF)
� threading�Thread�__init__�_pid�weakref�WeakKeyDictionary� _children�
_start_calledr
�_parent)�self�group�target�name�args�kwargsr r �A/usr/local/lib/python3.9/site-packages/billiard/dummy/__init__.pyr < s
zDummyProcess.__init__c C s> | j t� u sJ �d| _t| j d�r.d | j j| < tj�| � d S )NTr )r r
r �hasattrr r r �start�r r r r" r$ C s
zDummyProcess.startc C s | j r| �� sdS d S d S )Nr )r �is_aliver% r r r" �exitcodeJ s zDummyProcess.exitcode)�__name__�
__module__� __qualname__r r$ �propertyr' r r r r" r : s r c @ s* e Zd Zejd dkr ejZnejjZdS )r
r � N) r( r) r* �sys� version_info�
_Condition� notifyAll�
notify_all�__func__r r r r" r
X s r
c C s2 t � j} t| �D ]}|�� s| �|d � qt| �S �N)r
r �listr& �pop)�children�pr r r" r d s
r c C s d S r3 r r r r r" r l s r c @ s e Zd Zdd� Zdd� ZdS )� Namespacec K s | j �|� d S r3 )�__dict__�update)r �kwdsr r r" r r s zNamespace.__init__c C s\ t | j�� �}g }|D ]$\}}|�d�s|�d||f � q|�� d| jjt� d|�f S )N�_z%s=%rz%s(%s)z, )
r4 r9 �items�
startswith�append�sort� __class__r( �str�join)r r= �tempr �valuer r r" �__repr__u s
zNamespace.__repr__N)r( r) r* r rF r r r r" r8 p s r8 Tc C s t � | |�S r3 )�array)�typecode�sequence�lockr r r" �Array� s rK c @ s8 e Zd Zd dd�Zdd� Zdd� Zeee�Zdd � Zd
S ) �ValueTc C s || _ || _d S r3 )� _typecode�_value)r rH rE rJ r r r" r � s zValue.__init__c C s | j S r3 �rN r% r r r" �_get� s z
Value._getc C s
|| _ d S r3 rO )r rE r r r" �_set� s z
Value._setc C s dt | �j| j| jf S )Nz <%r(%r, %r)>)�typer( rM rN r% r r r" rF � s
�zValue.__repr__N)T) r( r) r* r rP rQ r+ rE rF r r r r" rL � s
rL c C s
t jt S r3 )r- �modulesr( r r r r" r � s r c C s d S r3 r r r r r" �shutdown� s rT r c C s ddl m} || ||�S )Nr )�
ThreadPool)Z
billiard.poolrU )Z processesZ initializerZinitargsrU r r r" r � s r )T)NNr )$r r- r rG r r r r r �queuer Zbilliard.connectionr �__all__r r r/ �AttributeErrorr
r �current_threadr
r r r r �objectr8 �dictr4 rK rL r rT r r r r r r" �<module>' s8