]> git.ipfire.org Git - thirdparty/Python/cpython.git/commitdiff
bpo-40275: Fix test.support.threading_helper (GH-20488)
authorVictor Stinner <vstinner@python.org>
Thu, 28 May 2020 14:37:37 +0000 (16:37 +0200)
committerGitHub <noreply@github.com>
Thu, 28 May 2020 14:37:37 +0000 (16:37 +0200)
* Add missing sys import
* Get verbose and gc_collect() from test.support
* Remove unused starttime variable.

Issues spotted by pyflakes.

Lib/test/support/threading_helper.py

index 96f7b3fcebfac23a82e35d5d92ef3256f8ea0516..0632577cdb303c0e4ad735c93ac6a223be3a3ae8 100644 (file)
@@ -1,6 +1,7 @@
+import _thread
 import contextlib
 import functools
-import _thread
+import sys
 import threading
 import time
 
@@ -47,7 +48,7 @@ def threading_cleanup(*original_values):
         values = None
 
         time.sleep(0.01)
-        gc_collect()
+        support.gc_collect()
 
 
 def reap_threads(func):
@@ -98,7 +99,7 @@ def wait_threads_exit(timeout=None):
                        f"(count: {count}, old count: {old_count})")
                 raise AssertionError(msg)
             time.sleep(0.010)
-            gc_collect()
+            support.gc_collect()
 
 
 def join_thread(thread, timeout=None):
@@ -124,7 +125,7 @@ def start_threads(threads, unlock=None):
                 t.start()
                 started.append(t)
         except:
-            if verbose:
+            if support.verbose:
                 print("Can't start %d threads, only %d threads started" %
                       (len(threads), len(started)))
             raise
@@ -133,7 +134,7 @@ def start_threads(threads, unlock=None):
         try:
             if unlock:
                 unlock()
-            endtime = starttime = time.monotonic()
+            endtime = time.monotonic()
             for timeout in range(1, 16):
                 endtime += 60
                 for t in started:
@@ -141,7 +142,7 @@ def start_threads(threads, unlock=None):
                 started = [t for t in started if t.is_alive()]
                 if not started:
                     break
-                if verbose:
+                if support.verbose:
                     print('Unable to join %d threads during a period of '
                           '%d minutes' % (len(started), timeout))
         finally: