o ‘iã@s@ddlZddlmZddlmZdd„ZGdd„dejjƒZdS)éNé)Ú SimpleQueuecOs&ddl}tjj|i|¤Ž| ¡dS)Nr)ÚgcÚmultiprocessingÚpoolZworkerZcollect)ÚargsÚkwargsr©r úi/var/www/html/eduruby.in/lip-sync/lip-sync-env/lib/python3.10/site-packages/torch/multiprocessing/pool.pyÚ clean_workers r c@s eZdZdZdd„Zdd„ZdS)ÚPoolzªPool implementation which uses our version of SimpleQueue. This lets us pass tensors in shared memory across processes instead of serializing the underlying data.cCs,tƒ|_tƒ|_|jjj|_|jjj|_dS)N) rÚ_inqueueÚ _outqueueZ_writerÚsendZ _quick_putÚ_readerÚrecvZ _quick_get)Úselfr r r Ú _setup_queuess zPool._setup_queuescCsŽt|jt|jƒƒD]:}|j|j|j|j|jf}t |dƒr#||j f7}|j t |d}|j  |¡|j dd¡|_d|_| ¡t d¡q dS)z€Bring the number of pool processes up to the specified number, for use after reaping workers which have exited. Ú_wrap_exception)ÚtargetrÚProcessZ PoolWorkerTz added workerN)ÚrangeZ _processesÚlenÚ_poolr rZ _initializerZ _initargsZ_maxtasksperchildÚhasattrrrr ÚappendÚnameÚreplaceÚdaemonÚstartÚutilÚdebug)rÚirÚwr r r Ú_repopulate_pools û    ðzPool._repopulate_poolN)Ú__name__Ú __module__Ú __qualname__Ú__doc__rr$r r r r r s r ) Zmultiprocessing.poolrZmultiprocessing.utilr Úqueuerr rr r r r r Ús