diff options
| author | Florent Xicluna <florent.xicluna@gmail.com> | 2011-11-11 20:05:50 +0100 |
|---|---|---|
| committer | Florent Xicluna <florent.xicluna@gmail.com> | 2011-11-11 20:05:50 +0100 |
| commit | 538a7efe8a864f96015957cff8d8c211582b7b27 (patch) | |
| tree | aa30d15c7a36320a1cb6bb106ab223a0d1b59f61 /Lib/concurrent | |
| parent | d5b4a3b8dddfbd98768c56745c6c43418bd6196e (diff) | |
| download | cpython-538a7efe8a864f96015957cff8d8c211582b7b27.tar.gz | |
Remove unused or redundant imports in concurrent.futures and multiprocessing.
Diffstat (limited to 'Lib/concurrent')
| -rw-r--r-- | Lib/concurrent/futures/_base.py | 1 | ||||
| -rw-r--r-- | Lib/concurrent/futures/process.py | 3 | ||||
| -rw-r--r-- | Lib/concurrent/futures/thread.py | 2 |
3 files changed, 2 insertions, 4 deletions
diff --git a/Lib/concurrent/futures/_base.py b/Lib/concurrent/futures/_base.py index 6cfded3075..3b097b505e 100644 --- a/Lib/concurrent/futures/_base.py +++ b/Lib/concurrent/futures/_base.py @@ -4,7 +4,6 @@ __author__ = 'Brian Quinlan (brian@sweetapp.com)' import collections -import functools import logging import threading import time diff --git a/Lib/concurrent/futures/process.py b/Lib/concurrent/futures/process.py index 9b2e0f3ab7..0575146b22 100644 --- a/Lib/concurrent/futures/process.py +++ b/Lib/concurrent/futures/process.py @@ -221,7 +221,7 @@ def _queue_management_worker(executor_reference, assert sentinels try: result_item = result_queue.get(sentinels=sentinels) - except SentinelReady as e: + except SentinelReady: # Mark the process pool broken so that submits fail right now. executor = executor_reference() if executor is not None: @@ -291,7 +291,6 @@ def _check_system_limits(): raise NotImplementedError(_system_limited) _system_limits_checked = True try: - import os nsems_max = os.sysconf("SC_SEM_NSEMS_MAX") except (AttributeError, ValueError): # sysconf not available or setting not available diff --git a/Lib/concurrent/futures/thread.py b/Lib/concurrent/futures/thread.py index fbac0887a5..95bb682565 100644 --- a/Lib/concurrent/futures/thread.py +++ b/Lib/concurrent/futures/thread.py @@ -74,7 +74,7 @@ def _worker(executor_reference, work_queue): work_queue.put(None) return del executor - except BaseException as e: + except BaseException: _base.LOGGER.critical('Exception in worker', exc_info=True) class ThreadPoolExecutor(_base.Executor): |