£Á°èZ¨Ä…–K§‚«“ô4“ÒÙ´dîfUÙÃÅ WKbyÊ¦•êŽ…È®FÒ¿ÊÎóCozá¬S@6{Í:›œêZÌ:Š•_%:¢¾¾~;‘Ã~èŠ©ÊÇí`ÔÑ©úë™µ'5I¿fš×WO%ø9¾«¾DK|€ùÍD”Ýs]nHÕ¶ê×Ó¼ãžªéUWŸÈË%DÒÕ¬ï‘]/Åcx ‰ï2ß]ä6G[]S£ÔÏ¯rs{úëóµmÒï#UQxo·õÞCe]"±/aÙ&Eã4ú9Jé_ÞåëdãöKë)AÞ ¯¹ægƒÛowÐø^d™ý½ßB7áyMä9ÜÖUã !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! U e5d��@sdddddddddd d ddd ddgZddlZddlZddlZddlZddlmZddlmZmZm Z m Z ddlmZmZm Z ddlmZGdd�dej�ZeZejZe��e�_dd�Zdd�ZGdd�de�ZeZeZd'dd�ZGd d!�d!e�Zd"d�Zd#d$�Z d(d&d�Z!eZ"dS))�Process�current_process�active_children�freeze_support�Lock�RLock� Semaphore�BoundedSemaphore� Condition�Event�Barrier�Queue�Manager�Pipe�Pool� JoinableQueue�N�)r)rrrr)r r r)rc@s4eZdZddddifdd�Zdd�Zedd��ZdS) �DummyProcessN�cCs8tj�||||||�d|_t��|_d|_t�|_ dS)NF) � threading�Thread�__init__Z_pid�weakref�WeakKeyDictionary� _children� _start_calledr�_parent)�self�group�target�name�args�kwargsrr�6/usr/lib64/python3.8/multiprocessing/dummy/__init__.pyr$s zDummyProcess.__init__cCsN|jt�k r td�|jt��d|_t|jd�r>d|jj|<tj� |�dS)Nz,Parent is {0!r} but current_process is {1!r}Tr) rr�RuntimeError�formatr�hasattrrrr�start�rrrr#r'+s��zDummyProcess.startcCs|jr|��sdSdSdS)Nr)r�is_aliver(rrr#�exitcode5szDummyProcess.exitcode)�__name__� __module__�__qualname__rr'�propertyr*rrrr#r"s rcCs2t�j}t|�D]}|��s|�|d�qt|�S�N)rr�listr)�pop)Zchildren�prrr#rDs cCsdSr/rrrrr#rKsc@seZdZdd�Zdd�ZdS)� NamespacecKs|j�|�dSr/)�__dict__�update)r�kwdsrrr#rSszNamespace.__init__cCsZt|j��}g}|D]$\}}|�d�s|�d||f�q|��d|jjd�|�fS)N�_z%s=%rz%s(%s)z, ) r0r4�items� startswith�append�sort� __class__r+�join)rr8Ztempr �valuerrr#�__repr__Us zNamespace.__repr__N)r+r,r-rr?rrrr#r3Rsr3TcCst�||�Sr/)�array)�typecodeZsequence�lockrrr#�ArrayasrCc@s8eZdZd dd�Zedd��Zejdd��Zdd�Zd S)�ValueTcCs||_||_dSr/)� _typecode�_value)rrAr>rBrrr#reszValue.__init__cCs|jSr/�rFr(rrr#r>iszValue.valuecCs ||_dSr/rG)rr>rrr#r>mscCsdt|�j|j|jfS)Nz<%s(%r, %r)>)�typer+rErFr(rrr#r?qszValue.__repr__N)T)r+r,r-rr.r>�setterr?rrrr#rDds rDcCs tjtSr/)�sys�modulesr+rrrr#r tscCsdSr/rrrrr#�shutdownwsrLrcCsddlm}||||�S)N�)� ThreadPool)ZpoolrN)Z processesZinitializerZinitargsrNrrr#rzs)T)NNr)#�__all__rrJrr@Z connectionrrrrrr r rZqueuerrrrZcurrent_threadrrrrr�objectr3�dictr0rCrDr rLrrrrrr#�sN�