{\r
try\r
{\r
- internal_begin_invoke([=]\r
- {\r
- is_running_ = false;\r
- }).wait();\r
+ wait();\r
}\r
catch(...)\r
{\r
CASPAR_LOG_CURRENT_EXCEPTION();\r
-\r
- clear();\r
- is_running_ = false;\r
- semaphore_.try_push(0);\r
}\r
+ \r
+ is_running_ = false;\r
+ semaphore_.try_push(0);\r
+\r
thread_.join();\r
}\r
\r
}\r
\r
private: \r
-\r
+ \r
template<typename Func>\r
auto internal_begin_invoke(Func&& func, task_priority priority = task_priority::normal_priority) -> boost::unique_future<decltype(func())> // noexcept\r
{ \r