]> granicus.if.org Git - python/commitdiff
Use test.support.start_threads() in threaded lru_cache tests.
authorSerhiy Storchaka <storchaka@gmail.com>
Sat, 30 May 2015 12:49:17 +0000 (15:49 +0300)
committerSerhiy Storchaka <storchaka@gmail.com>
Sat, 30 May 2015 12:49:17 +0000 (15:49 +0300)
Lib/test/test_functools.py

index 271d655dd09098776af82d3a190da1f0b5459638..e8cf848876416f185cf6836c5a7d0a1163935810 100644 (file)
@@ -1120,14 +1120,10 @@ class TestLRU:
         sys.setswitchinterval(1e-6)
         try:
             # create 5 threads in order to fill cache
-            threads = []
-            for k in range(5):
-                t = threading.Thread(target=full, args=[f, k, k])
-                t.start()
-                threads.append(t)
-
-            for t in threads:
-                t.join()
+            threads = [threading.Thread(target=full, args=[f, k, k])
+                       for k in range(5)]
+            with support.start_threads(threads):
+                pass
 
             hits, misses, maxsize, currsize = f.cache_info()
             self.assertEqual(hits, 45)
@@ -1135,16 +1131,11 @@ class TestLRU:
             self.assertEqual(currsize, 5)
 
             # create 5 threads in order to fill cache and 1 to clear it
-            cleaner = threading.Thread(target=clear, args=[f])
-            cleaner.start()
-            threads = [cleaner]
-            for k in range(5):
-                t = threading.Thread(target=full, args=[f, k, k])
-                t.start()
-                threads.append(t)
-
-            for t in threads:
-                t.join()
+            threads = [threading.Thread(target=clear, args=[f])]
+            threads += [threading.Thread(target=full, args=[f, k, k])
+                        for k in range(5)]
+            with support.start_threads(threads):
+                pass
         finally:
             sys.setswitchinterval(orig_si)