线程池修改

hikyuu_cpp/hikyuu/GlobalTaskGroup.h

@@ -25,6 +25,17 @@ namespace hku {
  */
 HKU_API ThreadPool* getGlobalTaskGroup();
 
+template <typename ResultType>
+using task_handle = std::future<ResultType>;
+
+/**
+ * 向全局任务池中增加任务
+ */
+template <typename FunctionType>
+task_handle<typename std::result_of<FunctionType()>::type> addTask(FunctionType f) {
+    return getGlobalTaskGroup()->submit(f);
+}
+
 /*
  * 内部函数，初始化全局任务组
  */

hikyuu_cpp/hikyuu/utilities/thread/ThreadPool.h

@@ -81,7 +81,7 @@ public:
         } else {
             m_master_work_queue.push(std::move(task));
         }
-        m_cv.notify_one();
+        m_cv.notify_all();
         return res;
     }
 
@@ -179,7 +179,7 @@ private:
         } else {
             // std::this_thread::yield();
             std::unique_lock<std::mutex> lk(m_cv_mutex);
-            m_cv.wait(lk);
+            m_cv.wait(lk, [=] { return this->m_done || !this->m_master_work_queue.empty(); });
         }
     }