Ticket #2067: 2067.1.patch

thread.hpp

@@ -530 +530 @@
             }
         }
         
         void join_all()
         {
-            boost::lock_guard<mutex> guard(m);
-            
-            for(std::list<thread*>::iterator it=threads.begin(),end=threads.end();
-                it!=end;
-                ++it)
+            std::list<thread*> joined;
+            for(;;)
             {
-                (*it)->join();
+                thread* t; // thread to join while mutex not held
+                {
+                    boost::lock_guard<mutex> guard(m);
+
+                    for(std::list<thread*>::iterator it=threads.begin(),end=threads.end();;++it)
+                    {
+                        if(it=end)
+                        {
+                            return;
+                        }
+                        std::list<thread*>::iterator const j=std::find(joined.begin(),joined.end(),*it);
+                        if(j==joined.end())
+                        {
+                            t = *it;
+                            break;
+                        }
+                    }
+                }
+                t->join();
             }
         }
         
         void interrupt_all()
         {