a
XC?hõ ã @ sø g d ¢Z ddlZddlZddlZddlZddlmZ ddlmZmZm Z m
Z
ddlm Z m Z m
Z
ddlmZ G dd „ d ejƒZeZejZe ¡ eƒ _d
d „ Zd d
„ ZG dd„ deƒZeZe Z d dd„Z G dd„ deƒZ dd„ Z dd„ Z d 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 @ s4 e Zd Zddddi fdd„Zdd„ Zedd„ ƒZdS ) Ú DummyProcessN© c C s8 t j | |||||¡ d | _t ¡ | _d| _tƒ | _ d S )NF)
Ú threadingÚThreadÚ__init__Z_pidÚweakrefÚWeakKeyDictionaryÚ _childrenÚ
_start_calledr Ú_parent)ÚselfÚgroupÚtargetÚnameÚargsÚkwargsr r úC/opt/alt/python39/lib64/python3.9/multiprocessing/dummy/__init__.pyr $ s
zDummyProcess.__init__c C sN | j tƒ ur td | j tƒ ¡ƒ‚d| _t| j dƒr>d | j j| < tj | ¡ d S )Nz,Parent is {0!r} but current_process is {1!r}Tr )
r r Ú RuntimeErrorÚformatr Úhasattrr r r Ústart©r r r r# r' + s ÿÿ zDummyProcess.startc C s | j r| ¡ sdS d S d S )Nr )r Úis_aliver( r r r# Úexitcode5 s zDummyProcess.exitcode)Ú__name__Ú
__module__Ú __qualname__r r' Úpropertyr* r r r r# r " s
r c C s2 t ƒ j} t| ƒD ]}| ¡ s| |d ¡ qt| ƒS ©N)r r Úlistr) Úpop)ZchildrenÚpr r r# r D s
r c C s d S r/ r r r r r# r K s r c @ s e Zd Zdd„ Zdd„ ZdS )Ú Namespacec K s | j |¡ d S r/ )Ú__dict__Úupdate)r Úkwdsr r r# r S s zNamespace.__init__c C sZ t | j ¡ ƒ}g }|D ]$\}}| d¡s| d||f ¡ q| ¡ d| jjd |¡f S )NÚ_z%s=%rz%s(%s)z, ) r0 r4 ÚitemsÚ
startswithÚappendÚsortÚ __class__r+ Újoin)r r8 Ztempr Úvaluer r r# Ú__repr__U s
zNamespace.__repr__N)r+ r, r- r r? r r r r# r3 R s r3 Tc C s t | |¡S r/ )Úarray)ÚtypecodeZsequenceÚlockr r r# ÚArraya s rC c @ s8 e Zd Zd
dd„Zedd„ ƒZejdd„ ƒZdd„ Zd S ) ÚValueTc C s || _ || _d S r/ )Ú _typecodeÚ_value)r rA r> rB r r r# r e s zValue.__init__c C s | j S r/ ©rF r( r r r# r> i s z Value.valuec C s
|| _ d S r/ rG )r r> r r r# r> m s c C s dt | ƒj| j| jf S )Nz <%s(%r, %r)>)Útyper+ rE rF r( r r r# r? q s zValue.__repr__N)T)r+ r, r- r r. r> Úsetterr? r r r r# rD d s
rD c C s
t jt S r/ )ÚsysÚmodulesr+ r r r r# r
t s r
c C s d S r/ r r r r r# Úshutdownw s rL r c C s ddl m} || ||ƒS )Né )Ú
ThreadPool)ZpoolrN )Z processesZ initializerZinitargsrN r r r# r z s r )T)NNr )#Ú__all__r rJ r r@ Z
connectionr r r r r r
r r Zqueuer r r r Zcurrent_threadr r r r r Úobjectr3 Údictr0 rC rD r
rL r r r r r r# Ú
s.