This is an archive of the discontinued Mercurial Phabricator instance.

Differential D3228

futures: switch to absolute and relative imports
AbandonedPublic

Authored by indygreg on Apr 10 2018, 9:26 PM.

Details

Reviewers
None
Group Reviewers
hg-reviewers
Summary

This makes the package conform with our importing policy,
silencing a number of warnings. It also makes the package usable
when it isn't named "concurrent.futures."

Diff Detail

Repository
rHG Mercurial
Lint
Lint Skipped
Unit
Unit Tests Skipped

Revision Contents
Changeset List

Diff 7946

mercurial/thirdparty/concurrent/futures/__init__.py

# Copyright 2009 Brian Quinlan. All Rights Reserved. # Copyright 2009 Brian Quinlan. All Rights Reserved.
# Licensed to PSF under a Contributor Agreement. # Licensed to PSF under a Contributor Agreement.
"""Execute computations asynchronously using threads or processes.""" """Execute computations asynchronously using threads or processes."""
from __future__ import absolute_import
__author__ = 'Brian Quinlan (brian@sweetapp.com)' __author__ = 'Brian Quinlan (brian@sweetapp.com)'
from concurrent.futures._base import (FIRST_COMPLETED, from ._base import (
FIRST_COMPLETED,
FIRST_EXCEPTION, FIRST_EXCEPTION,
ALL_COMPLETED, ALL_COMPLETED,
CancelledError, CancelledError,
TimeoutError, TimeoutError,
Future, Future,
Executor, Executor,
wait, wait,
as_completed) as_completed,
from concurrent.futures.thread import ThreadPoolExecutor )
from .thread import ThreadPoolExecutor
try: try:
from concurrent.futures.process import ProcessPoolExecutor from .process import ProcessPoolExecutor
except ImportError: except ImportError:
# some platforms don't have multiprocessing # some platforms don't have multiprocessing
pass pass

mercurial/thirdparty/concurrent/futures/_base.py

# Copyright 2009 Brian Quinlan. All Rights Reserved. # Copyright 2009 Brian Quinlan. All Rights Reserved.
# Licensed to PSF under a Contributor Agreement. # Licensed to PSF under a Contributor Agreement.
from __future__ import absolute_import
import collections import collections
import logging import logging
import threading import threading
import itertools import itertools
import time import time
import types import types
__author__ = 'Brian Quinlan (brian@sweetapp.com)' __author__ = 'Brian Quinlan (brian@sweetapp.com)'

mercurial/thirdparty/concurrent/futures/process.py

- reads _ResultItems from "Result Q", updates the future stored in the - reads _ResultItems from "Result Q", updates the future stored in the
"Work Items" dict and deletes the dict entry "Work Items" dict and deletes the dict entry
Process #1..n: Process #1..n:
- reads _CallItems from "Call Q", executes the calls, and puts the resulting - reads _CallItems from "Call Q", executes the calls, and puts the resulting
_ResultItems in "Request Q" _ResultItems in "Request Q"
""" """
from __future__ import absolute_import
import atexit import atexit
from concurrent.futures import _base from . import _base
import Queue as queue import Queue as queue
import multiprocessing import multiprocessing
import threading import threading
import weakref import weakref
import sys import sys
__author__ = 'Brian Quinlan (brian@sweetapp.com)' __author__ = 'Brian Quinlan (brian@sweetapp.com)'

mercurial/thirdparty/concurrent/futures/thread.py

# Copyright 2009 Brian Quinlan. All Rights Reserved. # Copyright 2009 Brian Quinlan. All Rights Reserved.
# Licensed to PSF under a Contributor Agreement. # Licensed to PSF under a Contributor Agreement.
"""Implements ThreadPoolExecutor.""" """Implements ThreadPoolExecutor."""
from __future__ import absolute_import
import atexit import atexit
from concurrent.futures import _base from . import _base
import itertools import itertools
import Queue as queue import Queue as queue
import threading import threading
import weakref import weakref
import sys import sys
try: try:
from multiprocessing import cpu_count from multiprocessing import cpu_count