o
    l¨Êh,  ã                   @   s8   d dl Zd dlmZmZ ddlmZ G dd„ deƒZdS )é    N)ÚSyncManagerÚStateé   )ÚLokyProcessc                   @   s   e Zd Zddd„ZdS )ÚLokyManagerN© c              	   C   sú   | j jtjks	J ‚|durt|dƒstdƒ‚tjdd�\}}tt	| ƒj
| j| jt| jƒ| j|||fd�| _d dd	„ | jjD ƒ¡}t	| ƒjd
 | | j_| j ¡  | ¡  | ¡ | _| ¡  tj| j _tjj| t	| ƒj| j| j| j| j | jfdd�| _dS )z.Spawn a server process for this manager objectNÚ__call__zinitializer must be a callableF)Úduplex)ÚtargetÚargsú:c                 s   s   � | ]}t |ƒV  qd S )N)Ústr)Ú.0Úir   r   úX/var/www/html/env/lib/python3.10/site-packages/joblib/externals/loky/backend/managers.pyÚ	<genexpr>#   s   € z$LokyManager.start.<locals>.<genexpr>ú-r   )r   Úexitpriority)Ú_stateÚvaluer   ÚINITIALÚhasattrÚ	TypeErrorÚmpÚPipeÚProcessÚtypeÚ_run_serverÚ	_registryÚ_addressÚbytesÚ_authkeyÚ_serializerÚ_processÚjoinÚ	_identityÚ__name__ÚnameÚstartÚcloseÚrecvÚSTARTEDÚutilÚFinalizeÚ_finalize_managerÚ_ClientÚshutdown)ÚselfÚinitializerÚinitargsÚreaderÚwriterÚidentr   r   r   r(      s4   ÿ
ÿþ



ÿüzLokyManager.start)Nr   )r&   Ú
__module__Ú__qualname__r(   r   r   r   r   r      s    r   )	Úmultiprocessingr   Úmultiprocessing.managersr   r   Úprocessr   r   r   r   r   r   r   Ú<module>   s   