JThhSSKrSSKJr SSKJr Sr"SS\RR5rg)N) SimpleQueueclSSKn[RR"U0UD6 UR 5 g)Nr)gcmultiprocessingpoolworkercollect)argskwargsrs R/var/www/auris/envauris/lib/python3.13/site-packages/torch/multiprocessing/pool.py clean_workerrs) 00JJLc$\rSrSrSrSrSrSrg)PoolzPool implementation which uses our version of SimpleQueue. This lets us pass tensors in shared memory across processes instead of serializing the underlying data. c[5Ul[5UlURRRUlURR RUlg)N) r_inqueue _outqueue_writersend _quick_put_readerrecv _quick_get)selfs r _setup_queuesPool._setup_queuessB#  $--//44..0055rc[UR[UR5- 5HnURUR UR URUR4n[US5(aX R4- nUR[US9nURRU5 URRSS5UlSUlUR#5 [$R&"S5 M g)zIncrease the number of pool processes to the specified number. Bring the number of pool processes up to the specified number, for use after reaping workers which have exited. _wrap_exception)targetr Process PoolWorkerTz added workerN)range _processeslen_poolrr _initializer _initargs_maxtasksperchildhasattrr r"rappendnamereplacedaemonstartutildebug)r_r ws r _repopulate_poolPool._repopulate_pools tTZZ89A !!&& Dt.//--// Lt rAs+##'?   $ $#'r