This is an archive of the discontinued Mercurial Phabricator instance.

Differential D3264

futures: switch to absolute and relative imports
ClosedPublic

Authored by indygreg on Apr 11 2018, 7:42 PM.

Details

Reviewers
durin42
Group Reviewers
hg-reviewers
Commits
rHG0a9c0d3480b2: futures: switch to absolute and relative imports
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
Automatic diff as part of commit; lint not applicable.
Unit
Automatic diff as part of commit; unit tests not applicable.

Event Timeline

indygreg created this revision.Apr 11 2018, 7:42 PM
durin42 accepted this revision.Apr 13 2018, 5:34 PM
This revision is now accepted and ready to land.Apr 13 2018, 5:34 PM
Closed by commit rHG0a9c0d3480b2: futures: switch to absolute and relative imports (authored by indygreg). · Explain WhyApr 13 2018, 5:45 PM
This revision was automatically updated to reflect the committed changes.

Revision Contents
Changeset List

Diff 8162

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