o 'jc@s*ddlmZddlmZmZdddZdS) )tqdm)ProcessPoolExecutor as_completedFc sL|dkrfdd|d|D}ng}|dkr+|fddt||dDSt|d=rBfdd||dD}nfd d||dD}t|d d d d }tt|fi|D]}qcWdn1spwYg} tt|D]$\} } z | | Wq}ty} z | | WYd} ~ q}d} ~ ww|| S) a A parallel version of the map function with a progress bar. Args: array (array-like): An array to iterate over. function (function): A python function to apply to the elements of array n_jobs (int, default=16): The number of cores to use use_kwargs (boolean, default=False): Whether to consider the elements of array as dictionaries of keyword arguments to function front_num (int, default=3): The number of iterations to run serially before kicking off the parallel job. Useful for catching bugs Returns: [function(array[0]), function(array[1]), ...] rc&g|]}r di|n|qSr.0afunction use_kwargsrr/var/www/html/Deteccion_Ine/venv/lib/python3.10/site-packages/paddleocr/ppstructure/table/table_metric/parallel.py sz$parallel_process..Ncrrrr r rrrs&) max_workerscsg|] }jfi|qSrZsubmitr r poolrrr scsg|]}|qSrrr rrrr"sitT)totalunitZ unit_scaleZleave)rrlenr enumerateappendresult Exception) arrayr Zn_jobsrZ front_numZfrontZfutureskwargsfoutifutureer)r rrrparallel_processs:  $ r%N)rFr)rconcurrent.futuresrrr%rrrrs