Viewing File: /opt/alt/python35/lib64/python3.5/multiprocessing/dummy/__pycache__/__init__.cpython-35.pyc
©ÕYfP ã @ s” d d d d d d d d d d d
d d d
d d g Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l m Z m Z m Z m
Z
d d l m Z m Z m
Z
d d l m Z Gd d „ d e j ƒ Z e Z e j Z e j ƒ e ƒ _ d d „ Z d d „ Z Gd d „ d e ƒ Z e Z e Z d d d „ Z Gd d! „ d! e ƒ Z d" d „ Z d# d$ „ Z d d f d% d „ Z! e Z" d S)&Ú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 @ sI e Z d Z d d d f i d d „ Z d d „ Z e d d „ ƒ Z d S)Ú DummyProcessNc C sP t j j | | | | | | ƒ d | _ t j ƒ | _ d | _ t ƒ | _ d S)NF)
Ú threadingÚThreadÚ__init__Z_pidÚweakrefÚWeakKeyDictionaryÚ _childrenÚ
_start_calledr Ú_parent)ÚselfÚgroupÚtargetÚnameÚargsÚkwargs© r" úC/opt/alt/python35/lib64/python3.5/multiprocessing/dummy/__init__.pyr $ s
zDummyProcess.__init__c C sW | j t ƒ k s t ‚ d | _ t | j d ƒ rC d | j j | <t j j | ƒ d S)NTr ) r r ÚAssertionErrorr Úhasattrr r r Ústart)r r" r" r# r& + s
zDummyProcess.startc C s" | j r | j ƒ r d Sd Sd S)Nr )r Úis_alive)r r" r" r# Úexitcode2 s zDummyProcess.exitcode)Ú__name__Ú
__module__Ú __qualname__r r& Úpropertyr( r" r" r" r# r " s r c C sI t ƒ j } x0 t | ƒ D]" } | j ƒ s | j | d ƒ q Wt | ƒ S)N)r r Úlistr' Úpop)ZchildrenÚpr" r" r# r A s
c C s d S)Nr" r" r" r" r# r H s c @ s( e Z d Z d d „ Z d d „ Z d S)Ú Namespacec K s | j j | ƒ d S)N)Ú__dict__Úupdate)r Úkwdsr" r" r# r P s zNamespace.__init__c C s t | j j ƒ ƒ } g } x: | D]2 \ } } | j d ƒ s" | j d | | f ƒ q" W| j ƒ d | j j d j | ƒ f S)NÚ_z%s=%rz%s(%s)z, ) r- r1 ÚitemsÚ
startswithÚappendÚsortÚ __class__r) Újoin)r r5 Ztempr Úvaluer" r" r# Ú__repr__R s
zNamespace.__repr__N)r) r* r+ r r< r" r" r" r# r0 O s r0 Tc C s t j | | ƒ S)N)Úarray)ÚtypecodeZsequenceÚlockr" r" r# ÚArray^ s r@ c @ sR e Z d Z d d d „ Z d d „ Z d d „ Z e e e ƒ Z d d „ Z d
S) ÚValueTc C s | | _ | | _ d S)N)Ú _typecodeÚ_value)r r> r; r? r" r" r# r b s zValue.__init__c C s | j S)N)rC )r r" r" r# Ú_gete s z
Value._getc C s
| | _ d S)N)rC )r r; r" r" r# Ú_setg s z
Value._setc C s d t | ƒ j | j | j f S)Nz <%s(%r, %r)>)Útyper) rB rC )r r" r" r# r< j s zValue.__repr__N) r) r* r+ r rD rE r, r; r< r" r" r" r# rA a s
rA c C s t j t S)N)ÚsysÚmodulesr) r" r" r" r# r
m s c C s d S)Nr" r" r" r" r# Úshutdownp s rI c C s d d l m } | | | | ƒ S)Né )Ú
ThreadPool)ZpoolrK )Z processesZ initializerZinitargsrK r" r" r# r s s )#Ú__all__r rG r r= Z
connectionr r r r r r
r r Zqueuer r r r Zcurrent_threadr r r r r Úobjectr0 Údictr- r@ rA r
rI r r r" r" r" r# Ú<module> s2 "
Back to Directory
File Manager