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
Lint Skipped
Unit
Unit Tests Skipped

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 8030

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