��ReL �@s�dZddgZddlmZddlmZddlmZddl m Z ddlmZddl mZdd lmZer�dd lmZmZmZmZmZddlmZeejejfZed�Zed �ZyddlZWnek rdZYnXdZdZedd��Zddd�Zddd�Z ddd�Z!esper}eZ"Z#ne Z"e!Z#dS)abConvenient parallelization of higher order functions. This module provides two helper functions, with appropriate fallbacks on Python 2 and on systems lacking support for synchronization mechanisms: - map_multiprocess - map_multithread These helpers work like Python 3's map, with two differences: - They don't guarantee the order of processing of the elements of the iterable. - The underlying process/thread pools chop the iterable into a number of chunks, so that for very long iterables using a large value for chunksize can make the job complete much faster than using the default value of 1. �map_multiprocess�map_multithread�)�contextmanager)�Pool)�DEFAULT_POOLSIZE)�PY2)�map)�MYPY_CHECK_RUNNING)�Callable�Iterable�Iterator�Union�TypeVar)�pool�S�TNTFi��c cs/z |VWd|j�|j�|j�XdS)z>Return a context manager making sure the pool closes properly.N)�close�join� terminate)r�r��/builddir/build/BUILDROOT/alt-python35-pip-20.2.4-5.el8.x86_64/opt/alt/python35/lib/python3.5/site-packages/pip/_internal/utils/parallel.py�closing4s r�cCs t||�S)z�Make an iterator applying func to each element in iterable. This function is the sequential fallback either on Python 2 where Pool.imap* doesn't react to KeyboardInterrupt or when sem_open is unavailable. )r)�func�iterable� chunksizerrr� _map_fallbackBsrcCs0tt��}|j|||�SWdQRXdS)z�Chop iterable into chunks and submit them to a process pool. For very long iterables using a large value for chunksize can make the job complete much faster than using the default value of 1. Return an unordered iterator of the results. N)r�ProcessPool�imap_unordered)rrrrrrr�_map_multiprocessMs rcCs3ttt��}|j|||�SWdQRXdS)z�Chop iterable into chunks and submit them to a thread pool. For very long iterables using a large value for chunksize can make the job complete much faster than using the default value of 1. Return an unordered iterator of the results. N)r� ThreadPoolrr)rrrrrrr�_map_multithreadZs r!)$�__doc__�__all__� contextlibr�multiprocessingrrZmultiprocessing.dummyr Zpip._vendor.requests.adaptersrZpip._vendor.sixr�pip._vendor.six.movesr�pip._internal.utils.typingr �typingr rrr rrrrZmultiprocessing.synchronize�ImportErrorZ LACK_SEM_OPEN�TIMEOUTrrrr!rrrrrr�s8(