
    h                        S SK r S SKrS SKrS SKrS SK JrJrJrJr  S SK Jr  S SK	J
r
  S SKJr  / SQr " S S\ R                  5      r \ R                   r " S	 S
\5      r\r\ R(                  r\R,                  " 5       \" 5       l        S rS r " S S\5      r\r\rSS jr " S S\5      rS r S r!SS jr"\
r#g! \ a    \ R$                  r N{f = f)    N)LockRLock	SemaphoreBoundedSemaphore)Event)Queue)Pipe)Processcurrent_processactive_childrenfreeze_supportr   r   r   r   	Conditionr   r   Managerr	   PoolJoinableQueuec                   >    \ rS rSrSSSS0 4S jrS r\S 5       rSrg)DummyProcess:   N c                     [         R                  R                  XX#XE5        S U l        [        R
                  " 5       U l        SU l        [        5       U l	        g )NF)
	threadingThread__init___pidweakrefWeakKeyDictionary	_children_start_calledr   _parent)selfgrouptargetnameargskwargss         ?D:\TimeStamps\venv\Lib\site-packages\billiard/dummy/__init__.pyr   DummyProcess.__init__<   sC    !!$vTJ	 224"&(    c                     U R                   [        5       L d   eSU l        [        U R                   S5      (       a  S U R                   R                  U '   [
        R                  R                  U 5        g )NTr   )r   r   r   hasattrr   r   r   startr    s    r&   r+   DummyProcess.startC   sX    ||0000!4<<--+/DLL""4(t$r(   c                 R    U R                   (       a  U R                  5       (       d  gg )Nr   )r   is_aliver,   s    r&   exitcodeDummyProcess.exitcodeJ   s    dmmoor(   )r   r   r   r   )	__name__
__module____qualname____firstlineno__r   r+   propertyr0   __static_attributes__r   r(   r&   r   r   :   s+    !$T2 )%  r(   r   c                       \ rS rSr\R
                  S   S:X  a  \R                  rSr
g\R                  R                  rSr
g)r   X   r      r   N)r2   r3   r4   r5   sysversion_info
_Condition	notifyAll
notify_all__func__r7   r   r(   r&   r   r   X   s1    
a))
))22
r(   r   c                      [        5       R                  n [        U 5       H,  nUR                  5       (       a  M  U R	                  US 5        M.     [        U 5      $ N)r   r   listr/   pop)childrenps     r&   r   r   d   sC     **H(^zz||LLD!  >r(   c                      g rB   r   r   r(   r&   r   r   l       r(   c                        \ rS rSrS rS rSrg)	Namespacep   c                 :    U R                   R                  U5        g rB   )__dict__update)r    kwdss     r&   r   Namespace.__init__r   s    T"r(   c                 F   [        U R                  R                  5       5      n/ nU H5  u  p4UR                  S5      (       a  M  UR	                  U< SU< 35        M7     UR                  5         U R                  R                  < S[        R                  SU5      < S3$ )N_=(, ))
rC   rM   items
startswithappendsort	__class__r2   strjoin)r    rW   tempr#   values        r&   __repr__Namespace.__repr__u   su    T]]((*+ KD??3''tU34 ! 			>>22CHHT44HIIr(   r   N)r2   r3   r4   r5   r   r`   r7   r   r(   r&   rJ   rJ   p   s    #Jr(   rJ   c                 .    [         R                   " X5      $ rB   )array)typecodesequencelocks      r&   Arrayrg      s    ;;x**r(   c                   B    \ rS rSrSS jrS rS r\" \\5      rS r	Sr
g)	Value   c                     Xl         X l        g rB   	_typecode_value)r    rd   r_   rf   s       r&   r   Value.__init__   s    !r(   c                     U R                   $ rB   rn   r,   s    r&   _get
Value._get   s    {{r(   c                     Xl         g rB   rq   )r    r_   s     r&   _set
Value._set   s    r(   c                 n    S[        U 5      R                  < SU R                  < SU R                  < S3$ )N<rT   rU   z)>)typer2   rm   rn   r,   s    r&   r`   Value.__repr__   s&    !%d!4!4!%> 	>r(   rl   NT)r2   r3   r4   r5   r   rr   ru   r6   r_   r`   r7   r   r(   r&   ri   ri      s"    T4 E>r(   ri   c                  0    [         R                  [           $ rB   )r;   modulesr2   r   r(   r&   r   r      s    ;;x  r(   c                      g rB   r   r   r(   r&   shutdownr      rH   r(   c                      SSK Jn  U" XU5      $ )Nr   )
ThreadPool)billiard.poolr   )	processesinitializerinitargsr   s       r&   r   r      s    (ih77r(   r{   )NNr   )$r   r;   r   rc   r   r   r   r   r   queuer   billiard.connectionr	   __all__r   r   r=   AttributeErrorr   r
   current_threadr   r   r   r   r   objectrJ   dictrC   rg   ri   r   r   r   r   r   r(   r&   <module>r      s   N  
   > >   $9## 0%%%J
3
 3 **%779  	J J +>F >$!	8
 e  %$$J%s   	B< <CC