Catch all exceptions in Runner.

base/base.pro

@@ -22,6 +22,7 @@ SOURCES += \
     condition.cpp \
     lower_case.cpp \
     normalize_unicode.cpp \
+    runner.cpp \
 
 HEADERS += \
     SRC_FIRST.hpp \

base/runner.cpp

@@ -0,0 +1,23 @@
+#include "runner.hpp"
+#include "logging.hpp"
+#include "exception.hpp"
+
+void threads::IRunner::CallAndCatchAll(RunnerFuncT const & f)
+{
+  try
+  {
+    f();
+  }
+  catch (RootException & e)
+  {
+    LOG(LERROR, ("Exception caught by runner", e.Msg()));
+  }
+  catch (::std::exception & e)
+  {
+    LOG(LERROR, ("Std exception caught by runner", e.what()));
+  }
+  catch (...)
+  {
+    LOG(LERROR, ("Unknown exception caught by runner"));
+  }
+}

base/runner.hpp

@@ -15,6 +15,9 @@ public:
 
   virtual void Run(RunnerFuncT const & f) const = 0;
 
+  // Helper function that calls f() and catches all exception.
+  static void CallAndCatchAll(RunnerFuncT const & f);
+
 protected:
 
   // Waits until all running threads stop.
@@ -29,7 +32,7 @@ class SimpleRunner : public IRunner
 public:
   virtual void Run(RunnerFuncT const & f) const
   {
-    f();
+    IRunner::CallAndCatchAll(f);
   }
 
 protected:

platform/ios_concurrent_runner.mm

@@ -1,8 +1,11 @@
 #include "concurrent_runner.hpp"
 
 #include "../base/assert.hpp"
+#include "../base/macros.hpp"
 #include "../base/logging.hpp"
 
+#include "../std/scoped_ptr.hpp"
+
 #include <dispatch/dispatch.h>
 
 namespace threads
@@ -41,9 +44,10 @@ namespace threads
 
     void operator()() const
     {
-      m_f();
-      // selfdestruct
-      delete this;
+      scoped_ptr<BoostExceptionFixer> scopedThis;
+      UNUSED_VALUE(scopedThis);
+
+      IRunner<RunnerFuncT>::CallAndCatchAll(f);
     }
   };
 

platform/qt_concurrent_runner.cpp

@@ -1,25 +1,29 @@
 #include "concurrent_runner.hpp"
 
+#include "../std/bind.hpp"
+
 #include <QtCore/QtConcurrentRun>
 #include <QtCore/QThreadPool>
 
 namespace threads
 {
-  ConcurrentRunner::ConcurrentRunner()
-  {
-  }
 
-  ConcurrentRunner::~ConcurrentRunner()
-  {
-  }
-
-  void ConcurrentRunner::Run(RunnerFuncT const & f) const
-  {
-    QtConcurrent::run(f);
-  }
-
-  void ConcurrentRunner::Join()
-  {
-    QThreadPool::globalInstance()->waitForDone();
-  }
+ConcurrentRunner::ConcurrentRunner()
+{
 }
+
+ConcurrentRunner::~ConcurrentRunner()
+{
+}
+
+void ConcurrentRunner::Run(RunnerFuncT const & f) const
+{
+  QtConcurrent::run(bind(&IRunner::CallAndCatchAll, f));
+}
+
+void ConcurrentRunner::Join()
+{
+  QThreadPool::globalInstance()->waitForDone();
+}
+
+}  // namespace threads