mofied packages with new namespaces

This commit is contained in:
Erin O'Connell
2017-09-05 23:12:46 -06:00
parent aacb7cb2d8
commit d7bfda713f
7 changed files with 13 additions and 14 deletions
+3 -4
View File
@@ -5,16 +5,15 @@ import sys
import multiprocessing
if sys.version_info.major < 3:
import concurrent3.futures as concurrent
else:
import concurrent27.futures as concurrent
else:
import concurrent3.futures as concurrent
def default_n():
return multiprocessing.cpu_count()
n = default_n()
pool = concurrent.futures.ThreadPoolExecutor(max_workers=n)
pool = concurrent.ThreadPoolExecutor(max_workers=n)
callbacks = []
results = []
+3 -3
View File
@@ -5,7 +5,7 @@
__author__ = 'Brian Quinlan (brian@sweetapp.com)'
from concurrent.futures._base import (FIRST_COMPLETED,
from concurrent27.futures._base import (FIRST_COMPLETED,
FIRST_EXCEPTION,
ALL_COMPLETED,
CancelledError,
@@ -14,10 +14,10 @@ from concurrent.futures._base import (FIRST_COMPLETED,
Executor,
wait,
as_completed)
from concurrent.futures.thread import ThreadPoolExecutor
from concurrent27.futures.thread import ThreadPoolExecutor
try:
from concurrent.futures.process import ProcessPoolExecutor
from concurrent27.futures.process import ProcessPoolExecutor
except ImportError:
# some platforms don't have multiprocessing
pass
+1 -1
View File
@@ -44,7 +44,7 @@ Process #1..n:
"""
import atexit
from concurrent.futures import _base
from concurrent27.futures import _base
import Queue as queue
import multiprocessing
import threading
+1 -1
View File
@@ -4,7 +4,7 @@
"""Implements ThreadPoolExecutor."""
import atexit
from concurrent.futures import _base
from concurrent27.futures import _base
import Queue as queue
import threading
import weakref
+3 -3
View File
@@ -5,7 +5,7 @@
__author__ = 'Brian Quinlan (brian@sweetapp.com)'
from concurrent.futures._base import (FIRST_COMPLETED,
from concurrent3.futures._base import (FIRST_COMPLETED,
FIRST_EXCEPTION,
ALL_COMPLETED,
CancelledError,
@@ -14,5 +14,5 @@ from concurrent.futures._base import (FIRST_COMPLETED,
Executor,
wait,
as_completed)
from concurrent.futures.process import ProcessPoolExecutor
from concurrent.futures.thread import ThreadPoolExecutor
from concurrent3.futures.process import ProcessPoolExecutor
from concurrent3.futures.thread import ThreadPoolExecutor
+1 -1
View File
@@ -47,7 +47,7 @@ __author__ = 'Brian Quinlan (brian@sweetapp.com)'
import atexit
import os
from concurrent.futures import _base
from concurrent3.futures import _base
import queue
from queue import Full
import multiprocessing
+1 -1
View File
@@ -6,7 +6,7 @@
__author__ = 'Brian Quinlan (brian@sweetapp.com)'
import atexit
from concurrent.futures import _base
from concurrent3.futures import _base
import itertools
import queue
import threading