
    Ih                        d dl Z d dlZd dlZd dlZd dl mZmZmZmZ d dl mZ d dl	m
Z
 d dlmZ g dZ G d de j                        Z	 e j                   Z G d	 d
e      ZeZe j(                  Z ej,                          e       _        d Zd Z G d de      ZeZeZddZ G d de      Zd Z d Z!ddZ"e
Z#y# e$ r e j$                  ZY xw xY w)    N)LockRLock	SemaphoreBoundedSemaphore)Event)Queue)Pipe)Processcurrent_processactive_childrenfreeze_supportr   r   r   r   	Conditionr   r   Managerr	   PoolJoinableQueuec                   4    e Zd Zddddi fdZd Zed        Zy)DummyProcessN c                     t         j                  j                  | |||||       d | _        t	        j
                         | _        d| _        t               | _	        y )NF)
	threadingThread__init___pidweakrefWeakKeyDictionary	_children_start_calledr   _parent)selfgrouptargetnameargskwargss         P/var/www/html/planif/env/lib/python3.12/site-packages/billiard/dummy/__init__.pyr   zDummyProcess.__init__<   sI    !!$vtT6J	 224"&(    c                     | j                   t               u sJ d| _        t        | j                   d      rd | j                   j                  | <   t
        j                  j                  |        y )NTr   )r   r   r   hasattrr   r   r   startr   s    r%   r)   zDummyProcess.startC   sU    ||0000!4<<-+/DLL""4(t$r&   c                 >    | j                   r| j                         syy )Nr   )r   is_aliver*   s    r%   exitcodezDummyProcess.exitcodeJ   s    dmmor&   )__name__
__module____qualname__r   r)   propertyr-   r   r&   r%   r   r   :   s+    !$T2 )%  r&   r   c                   v    e Zd Zej                  d   dk(  rej                  Zyej                  j                  Zy)r   r      N)	r.   r/   r0   sysversion_info
_Condition	notifyAll
notify_all__func__r   r&   r%   r   r   X   s1    
a))
))22
r&   r   c                      t               j                  } t        |       D ]%  }|j                         r| j	                  |d        ' t        |       S N)r   r   listr,   pop)childrenps     r%   r   r   d   sF     **H(^ "zz|LLD!" >r&   c                       y r;   r   r   r&   r%   r   r   l       r&   c                       e Zd Zd Zd Zy)	Namespacec                 :    | j                   j                  |       y r;   )__dict__update)r   kwdss     r%   r   zNamespace.__init__r   s    T"r&   c                 0   t        | j                  j                               }g }|D ]-  \  }}|j                  d      r|j	                  |d|       / |j                          | j                  j                  dt        j                  d|      dS )N_=(, ))
r<   rE   items
startswithappendsort	__class__r.   strjoin)r   rN   tempr"   values        r%   __repr__zNamespace.__repr__u   sy    T]]((*+  	5KD%??3'tU34	5 			>>22CHHT44HIIr&   N)r.   r/   r0   r   rW   r   r&   r%   rC   rC   p   s    #Jr&   rC   c                 .    t        j                   | |      S r;   )array)typecodesequencelocks      r%   Arrayr]      s    ;;x**r&   c                   8    e Zd ZddZd Zd Z eee      Zd Zy)Valuec                      || _         || _        y r;   )	_typecode_value)r   rZ   rV   r\   s       r%   r   zValue.__init__   s    !r&   c                     | j                   S r;   rb   r*   s    r%   _getz
Value._get   s    {{r&   c                     || _         y r;   rd   )r   rV   s     r%   _setz
Value._set   s	    r&   c                 h    dt        |       j                  d| j                  d| j                  dS )N<rK   rL   z)>)typer.   ra   rb   r*   s    r%   rW   zValue.__repr__   s&    !%d!4!4!%> 	>r&   NT)	r.   r/   r0   r   re   rg   r1   rV   rW   r   r&   r%   r_   r_      s"    T4 E>r&   r_   c                  0    t         j                  t           S r;   )r4   modulesr.   r   r&   r%   r   r      s    ;;x  r&   c                       y r;   r   r   r&   r%   shutdownro      rA   r&   c                 "    ddl m}  || ||      S )Nr   )
ThreadPool)billiard.poolrq   )	processesinitializerinitargsrq   s       r%   r   r      s    (ih77r&   rk   )NNr   )$r   r4   r   rY   r   r   r   r   r   queuer   billiard.connectionr	   __all__r   r   r6   AttributeErrorr   r
   current_threadr   r   r   r   r   objectrC   dictr<   r]   r_   r   ro   r   r   r   r&   r%   <module>r}      s   N  
   > >   $9## 0%%%J
3
 3 **7g779  	J J +>F >$!	8
 e  %$$J%s   	B: :CC