assert_python_ok, assert_python_failure, temp_dir,
spawn_python, kill_python)
-# We look inside the context module to find out which
-# start methods we can check
-from multiprocessing.context import _concrete_contexts
+# Look up which start methods are available to test
+import multiprocessing
+AVAILABLE_START_METHODS = set(multiprocessing.get_all_start_methods())
verbose = support.verbose
p = Pool(5)
results = []
p.map_async(f, [1, 2, 3], callback=results.extend)
- deadline = time.time() + 2 # up to 2 s to report the results
+ deadline = time.time() + 5 # up to 5 s to report the results
while not results:
time.sleep(0.05)
if time.time() > deadline:
p = Pool(5)
results = []
p.map_async(int, [1, 4, 9], callback=results.extend)
-deadline = time.time() + 2 # up to 2 s to report the results
+deadline = time.time() + 5 # up to 5 s to report the results
while not results:
time.sleep(0.05)
if time.time() > deadline:
maxDiff = None # Show full tracebacks on subprocess failure
def setUp(self):
- if self.start_method not in _concrete_contexts:
+ if self.start_method not in AVAILABLE_START_METHODS:
self.skipTest("%r start method not available" % self.start_method)
def _check_output(self, script_name, exit_code, out, err):