Current Path: > > opt > alt > python37 > lib > python3.7 > site-packages > pip > _internal > utils
Operation : Linux premium131.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64 Software : Apache Server IP : 162.0.232.56 | Your IP: 216.73.216.111 Domains : 1034 Domain(s) Permission : [ 0755 ]
Name | Type | Size | Last Modified | Actions |
---|---|---|---|---|
__pycache__ | Directory | - | - | |
__init__.py | File | 0 bytes | November 13 2023 21:31:06. | |
appdirs.py | File | 1349 bytes | November 13 2023 21:31:06. | |
compat.py | File | 9489 bytes | November 13 2023 21:31:06. | |
compatibility_tags.py | File | 5439 bytes | November 13 2023 21:31:06. | |
datetime.py | File | 295 bytes | November 13 2023 21:31:06. | |
deprecation.py | File | 3318 bytes | November 13 2023 21:31:06. | |
direct_url_helpers.py | File | 4359 bytes | November 13 2023 21:31:06. | |
distutils_args.py | File | 1350 bytes | November 13 2023 21:31:06. | |
encoding.py | File | 1284 bytes | November 13 2023 21:31:06. | |
entrypoints.py | File | 1219 bytes | November 13 2023 21:31:06. | |
filesystem.py | File | 6943 bytes | November 13 2023 21:31:06. | |
filetypes.py | File | 571 bytes | November 13 2023 21:31:06. | |
glibc.py | File | 3297 bytes | November 13 2023 21:31:06. | |
hashes.py | File | 4678 bytes | November 13 2023 21:31:06. | |
inject_securetransport.py | File | 810 bytes | November 13 2023 21:31:06. | |
logging.py | File | 13093 bytes | November 13 2023 21:31:06. | |
misc.py | File | 28331 bytes | November 13 2023 21:31:06. | |
models.py | File | 1201 bytes | November 13 2023 21:31:06. | |
packaging.py | File | 3035 bytes | November 13 2023 21:31:06. | |
parallel.py | File | 3404 bytes | November 13 2023 21:31:06. | |
pkg_resources.py | File | 1254 bytes | November 13 2023 21:31:06. | |
setuptools_build.py | File | 5058 bytes | November 13 2023 21:31:06. | |
subprocess.py | File | 9924 bytes | November 13 2023 21:31:06. | |
temp_dir.py | File | 8378 bytes | November 13 2023 21:31:06. | |
typing.py | File | 1401 bytes | November 13 2023 21:31:06. | |
unpacking.py | File | 9488 bytes | November 13 2023 21:31:06. | |
urls.py | File | 1527 bytes | November 13 2023 21:31:06. | |
virtualenv.py | File | 3706 bytes | November 13 2023 21:31:06. | |
wheel.py | File | 7303 bytes | November 13 2023 21:31:06. |
"""Convenient 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. """ __all__ = ['map_multiprocess', 'map_multithread'] from contextlib import contextmanager from multiprocessing import Pool as ProcessPool from multiprocessing.dummy import Pool as ThreadPool from pip._vendor.requests.adapters import DEFAULT_POOLSIZE from pip._vendor.six import PY2 from pip._vendor.six.moves import map from pip._internal.utils.typing import MYPY_CHECK_RUNNING if MYPY_CHECK_RUNNING: from typing import Callable, Iterable, Iterator, Union, TypeVar from multiprocessing import pool Pool = Union[pool.Pool, pool.ThreadPool] S = TypeVar('S') T = TypeVar('T') # On platforms without sem_open, multiprocessing[.dummy] Pool # cannot be created. try: import multiprocessing.synchronize # noqa except ImportError: LACK_SEM_OPEN = True else: LACK_SEM_OPEN = False # Incredibly large timeout to work around bpo-8296 on Python 2. TIMEOUT = 2000000 @contextmanager def closing(pool): # type: (Pool) -> Iterator[Pool] """Return a context manager making sure the pool closes properly.""" try: yield pool finally: # For Pool.imap*, close and join are needed # for the returned iterator to begin yielding. pool.close() pool.join() pool.terminate() def _map_fallback(func, iterable, chunksize=1): # type: (Callable[[S], T], Iterable[S], int) -> Iterator[T] """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. """ return map(func, iterable) def _map_multiprocess(func, iterable, chunksize=1): # type: (Callable[[S], T], Iterable[S], int) -> Iterator[T] """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. """ with closing(ProcessPool()) as pool: return pool.imap_unordered(func, iterable, chunksize) def _map_multithread(func, iterable, chunksize=1): # type: (Callable[[S], T], Iterable[S], int) -> Iterator[T] """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. """ with closing(ThreadPool(DEFAULT_POOLSIZE)) as pool: return pool.imap_unordered(func, iterable, chunksize) if LACK_SEM_OPEN or PY2: map_multiprocess = map_multithread = _map_fallback else: map_multiprocess = _map_multiprocess map_multithread = _map_multithread
SILENT KILLER Tool