]> git.ipfire.org Git - thirdparty/Python/cpython.git/commitdiff
Issue #8799: Reduce timing sensitivity of condition test by explicitly
authorKristjan Valur Jonsson <sweskman@gmail.com>
Mon, 11 Nov 2013 11:29:04 +0000 (11:29 +0000)
committerKristjan Valur Jonsson <sweskman@gmail.com>
Mon, 11 Nov 2013 11:29:04 +0000 (11:29 +0000)
delaying the main thread so that it doesn't race ahead of the workers.

Lib/test/lock_tests.py

index 1a24bdeed373fbd075e2c698d18616f55c941442..1cbcea2343968aca703a7f6f5e50de33fa4061b1 100644 (file)
@@ -418,6 +418,17 @@ class ConditionTests(BaseTestCase):
         self.assertRaises(RuntimeError, cond.notify)
 
     def _check_notify(self, cond):
+        # Note that this test is sensitive to timing.  If the worker threads
+        # don't execute in a timely fashion, the main thread may think they
+        # are further along then they are.  The main thread therefore issues
+        # _wait() statements to try to make sure that it doesn't race ahead
+        # of the workers.
+        # Secondly, this test assumes that condition variables are not subject
+        # to spurious wakeups.  The absence of spurious wakeups is an implementation
+        # detail of Condition Cariables in current CPython, but in general, not
+        # a guaranteed property of condition variables as a programming
+        # construct.  In particular, it is possible that this can no longer
+        # be conveniently guaranteed should their implementation ever change.
         N = 5
         results1 = []
         results2 = []
@@ -445,6 +456,9 @@ class ConditionTests(BaseTestCase):
             _wait()
         self.assertEqual(results1, [(True, 1)] * 3)
         self.assertEqual(results2, [])
+        # first wait, to ensure all workers settle into cond.wait() before
+        # we continue. See issue #8799
+        _wait()
         # Notify 5 threads: they might be in their first or second wait
         cond.acquire()
         cond.notify(5)
@@ -455,6 +469,7 @@ class ConditionTests(BaseTestCase):
             _wait()
         self.assertEqual(results1, [(True, 1)] * 3 + [(True, 2)] * 2)
         self.assertEqual(results2, [(True, 2)] * 3)
+        _wait() # make sure all workers settle into cond.wait()
         # Notify all threads: they are all in their second wait
         cond.acquire()
         cond.notify_all()