summaryrefslogtreecommitdiff
path: root/Lib/concurrent/futures
diff options
context:
space:
mode:
authorFlorent Xicluna <florent.xicluna@gmail.com>2011-11-11 20:05:50 +0100
committerFlorent Xicluna <florent.xicluna@gmail.com>2011-11-11 20:05:50 +0100
commit538a7efe8a864f96015957cff8d8c211582b7b27 (patch)
treeaa30d15c7a36320a1cb6bb106ab223a0d1b59f61 /Lib/concurrent/futures
parentd5b4a3b8dddfbd98768c56745c6c43418bd6196e (diff)
downloadcpython-538a7efe8a864f96015957cff8d8c211582b7b27.tar.gz
Remove unused or redundant imports in concurrent.futures and multiprocessing.
Diffstat (limited to 'Lib/concurrent/futures')
-rw-r--r--Lib/concurrent/futures/_base.py1
-rw-r--r--Lib/concurrent/futures/process.py3
-rw-r--r--Lib/concurrent/futures/thread.py2
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):