diff options
Diffstat (limited to 'Lib/test/test_threading.py')
| -rw-r--r-- | Lib/test/test_threading.py | 32 | 
1 files changed, 16 insertions, 16 deletions
diff --git a/Lib/test/test_threading.py b/Lib/test/test_threading.py index 4d30ee4e07..7bd3082842 100644 --- a/Lib/test/test_threading.py +++ b/Lib/test/test_threading.py @@ -600,22 +600,22 @@ class ThreadTests(BaseTestCase):          self.assertIn(LOOKING_FOR, repr(t)) # we waited at least 5 seconds      def test_BoundedSemaphore_limit(self): -       # BoundedSemaphore should raise ValueError if released too often. -       for limit in range(1, 10): -           bs = threading.BoundedSemaphore(limit) -           threads = [threading.Thread(target=bs.acquire) -                      for _ in range(limit)] -           for t in threads: -               t.start() -           for t in threads: -               t.join() -           threads = [threading.Thread(target=bs.release) -                      for _ in range(limit)] -           for t in threads: -               t.start() -           for t in threads: -               t.join() -           self.assertRaises(ValueError, bs.release) +        # BoundedSemaphore should raise ValueError if released too often. +        for limit in range(1, 10): +            bs = threading.BoundedSemaphore(limit) +            threads = [threading.Thread(target=bs.acquire) +                       for _ in range(limit)] +            for t in threads: +                t.start() +            for t in threads: +                t.join() +            threads = [threading.Thread(target=bs.release) +                       for _ in range(limit)] +            for t in threads: +                t.start() +            for t in threads: +                t.join() +            self.assertRaises(ValueError, bs.release)  class ThreadJoinOnShutdown(BaseTestCase):  | 
