[Python-checkins] r75635 - in python/branches/release31-maint: Lib/test/test_thread.py

[antoine.pitrou]

Author: antoine.pitrou
Date: Fri Oct 23 20:35:18 2009
New Revision: 75635

Log:
Merged revisions 75634 via svnmerge from 
svn+ssh://pythondev@svn.python.org/python/branches/py3k

................
  r75634 | antoine.pitrou | 2009-10-23 20:34:17 +0200 (ven., 23 oct. 2009) | 9 lines
  
  Merged revisions 75633 via svnmerge from 
  svn+ssh://pythondev@svn.python.org/python/trunk
  
  ........
    r75633 | antoine.pitrou | 2009-10-23 20:32:15 +0200 (ven., 23 oct. 2009) | 3 lines
    
    Issue #7194: test_thread could try to release an unacquired mutex (and fail).
  ........
................


Modified:
   python/branches/release31-maint/   (props changed)
   python/branches/release31-maint/Lib/test/test_thread.py

Modified: python/branches/release31-maint/Lib/test/test_thread.py
==============================================================================
--- python/branches/release31-maint/Lib/test/test_thread.py	(original)
+++ python/branches/release31-maint/Lib/test/test_thread.py	Fri Oct 23 20:35:18 2009
@@ -24,6 +24,7 @@
         self.done_mutex.acquire()
         self.running_mutex = thread.allocate_lock()
         self.random_mutex = thread.allocate_lock()
+        self.created = 0
         self.running = 0
         self.next_ident = 0
 
@@ -35,6 +36,7 @@
             self.next_ident += 1
             verbose_print("creating task %s" % self.next_ident)
             thread.start_new_thread(self.task, (self.next_ident,))
+            self.created += 1
             self.running += 1
 
     def task(self, ident):
@@ -45,7 +47,7 @@
         verbose_print("task %s done" % ident)
         with self.running_mutex:
             self.running -= 1
-            if self.running == 0:
+            if self.created == NUMTASKS and self.running == 0:
                 self.done_mutex.release()
 
     def test_starting_threads(self):
@@ -87,6 +89,7 @@
             for tss in (262144, 0x100000):
                 verbose_print("trying stack_size = (%d)" % tss)
                 self.next_ident = 0
+                self.created = 0
                 for i in range(NUMTASKS):
                     self.newtask()