+ jj^RIt^RIHt^RIHtRt!RR]PP4tR#)N) SimpleQueuecn^RIp\PP!V/VBVP 4R#)rN)gcmultiprocessingpoolworkercollect)argskwargsrs*, [/home/luca/screen-checking/.venv/lib/python3.14/site-packages/torch/multiprocessing/pool.py clean_workerr s) 00JJLc0a]tRt^toRtRtRtRtVtR#)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\4Vn\4VnVPPPVnVPP PVnR#)N) r_inqueue _outqueue_writersend _quick_put_readerrecv _quick_get)selfs&r _setup_queuesPool._setup_queuessB#  $--//44..0055rc .\VP\VP4, 4FpVPVP VP VPVP3p\VR4'dW P3, pVP\VR7pVPPV4VPPRR4VnRVnVP#4\$P&!R4K R#)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_maxtasksperchildhasattrrr r appendnamereplacedaemonstartutildebug)r_r ws& r _repopulate_poolPool._repopulate_pools tTZZ89A !!&& Dt.//--// Lt rAs+##'?   $ $#'r