refactor(thread): 优化线程池submit函数参数传递

Author: fasiondog

hikyuu_cpp/hikyuu/utilities/thread/GlobalMQStealThreadPool.h

@@ -104,14 +104,14 @@ class HKU_UTILS_API GlobalMQStealThreadPool {
 
     /** 向线程池提交任务 */
     template <typename FunctionType>
-    auto submit(FunctionType f) {
+    auto submit(FunctionType&& f) {
         if (m_thread_need_stop.isSet() || m_done) {
             throw std::logic_error(
               "You can't submit a task to the stopped GlobalMQStealThreadPool!");
         }
 
         typedef typename std::invoke_result<FunctionType>::type result_type;
-        std::packaged_task<result_type()> task(f);
+        std::packaged_task<result_type()> task(std::forward<FunctionType>(f));
         task_handle<result_type> res(task.get_future());
 
         // 如果是本地线程且线程仍未终止，则加入自身队列

hikyuu_cpp/hikyuu/utilities/thread/GlobalMQThreadPool.h

@@ -103,13 +103,13 @@ class HKU_UTILS_API GlobalMQThreadPool {
 
     /** 向线程池提交任务 */
     template <typename FunctionType>
-    auto submit(FunctionType f) {
+    auto submit(FunctionType&& f) {
         if (m_thread_need_stop.isSet() || m_done) {
             throw std::logic_error("You can't submit a task to the stopped GlobalMQThreadPool!");
         }
 
         typedef typename std::invoke_result<FunctionType>::type result_type;
-        std::packaged_task<result_type()> task(f);
+        std::packaged_task<result_type()> task(std::forward<FunctionType>(f));
         task_handle<result_type> res(task.get_future());
 
         // 向空队列或任务数最小的队列中加入任务

hikyuu_cpp/hikyuu/utilities/thread/GlobalStealThreadPool.h

@@ -158,14 +158,14 @@ class HKU_UTILS_API GlobalStealThreadPool {
 
     /** 向线程池提交任务 */
     template <typename FunctionType>
-    auto submit(FunctionType f) {
+    auto submit(FunctionType&& f) {
         if (m_thread_need_stop.isSet() || m_done.load(std::memory_order_acquire)) {
             throw std::logic_error(
               "You can't submit a task to the stopped GlobalStealThreadPool!!");
         }
 
         typedef typename std::invoke_result<FunctionType>::type result_type;
-        std::packaged_task<result_type()> task(f);
+        std::packaged_task<result_type()> task(std::forward<FunctionType>(f));
         task_handle<result_type> res(task.get_future());
 
         std::thread::id id = std::this_thread::get_id();

hikyuu_cpp/hikyuu/utilities/thread/GlobalThreadPool.h

@@ -91,12 +91,12 @@ class HKU_UTILS_API GlobalThreadPool {
 
     /** 向线程池提交任务 */
     template <typename FunctionType>
-    auto submit(FunctionType f) {
+    auto submit(FunctionType&& f) {
         if (m_thread_need_stop.isSet() || m_done) {
             throw std::logic_error("You can't submit a task to the stopped task group!");
         }
         typedef typename std::invoke_result<FunctionType>::type result_type;
-        std::packaged_task<result_type()> task(f);
+        std::packaged_task<result_type()> task(std::forward<FunctionType>(f));
         task_handle<result_type> res(task.get_future());
         m_master_work_queue.push(std::move(task));
         return res;

hikyuu_cpp/hikyuu/utilities/thread/MQStealThreadPool.h

@@ -106,7 +106,7 @@ class HKU_UTILS_API MQStealThreadPool {
 
     /** 向线程池提交任务 */
     template <typename FunctionType>
-    auto submit(FunctionType f) {
+    auto submit(FunctionType&& f) {
         if (m_done) {
             throw std::logic_error("You can't submit a task to the stopped MQStealThreadPool!");
         }
@@ -118,7 +118,7 @@ class HKU_UTILS_API MQStealThreadPool {
         }
 
         typedef typename std::invoke_result<FunctionType>::type result_type;
-        std::packaged_task<result_type()> task(f);
+        std::packaged_task<result_type()> task(std::forward<FunctionType>(f));
         task_handle<result_type> res(task.get_future());
 
         // 如果是本地线程且线程仍未终止，则加入自身队列

hikyuu_cpp/hikyuu/utilities/thread/MQThreadPool.h

@@ -105,13 +105,13 @@ class HKU_UTILS_API MQThreadPool {
 
     /** 向线程池提交任务 */
     template <typename FunctionType>
-    auto submit(FunctionType f) {
+    auto submit(FunctionType &&f) {
         if (m_done) {
             throw std::logic_error("You can't submit a task to the stopped MQThreadPool!");
         }
 
         typedef typename std::invoke_result<FunctionType>::type result_type;
-        std::packaged_task<result_type()> task(f);
+        std::packaged_task<result_type()> task(std::forward<FunctionType>(f));
         task_handle<result_type> res(task.get_future());
 
         // 向空队列或任务数最小的队列中加入任务

hikyuu_cpp/hikyuu/utilities/thread/StealThreadPool.h

@@ -109,7 +109,7 @@ class HKU_UTILS_API StealThreadPool {
 
     /** 向线程池提交任务 */
     template <typename FunctionType>
-    auto submit(FunctionType f) {
+    auto submit(FunctionType&& f) {
         if (m_done) {
             throw std::logic_error("You can't submit a task to the stopped StealThreadPool!!");
         }
@@ -121,7 +121,7 @@ class HKU_UTILS_API StealThreadPool {
         }
 
         typedef typename std::invoke_result<FunctionType>::type result_type;
-        std::packaged_task<result_type()> task(f);
+        std::packaged_task<result_type()> task(std::forward<FunctionType>(f));
         task_handle<result_type> res(task.get_future());
         if (index != -1 && !m_interrupt_flags[index]) {
             // 本地线程任务从前部入队列（递归成栈）

hikyuu_cpp/hikyuu/utilities/thread/ThreadPool.h

@@ -84,12 +84,12 @@ class ThreadPool {
 
     /** 向线程池提交任务 */
     template <typename FunctionType>
-    auto submit(FunctionType f) {
+    auto submit(FunctionType&& f) {
         if (m_done) {
             throw std::logic_error("You can't submit a task to the stopped task group!");
         }
         typedef typename std::invoke_result<FunctionType>::type result_type;
-        std::packaged_task<result_type()> task(f);
+        std::packaged_task<result_type()> task(std::forward<FunctionType>(f));
         task_handle<result_type> res(task.get_future());
         m_master_work_queue.push(std::move(task));
         return res;