Merge pull request #460 from fasiondog/feature/coro

feat(thread): 添加协程执行器支持和完整的协程功能, 切换至c++20编译

Author: fasiondog

hikyuu_cpp/hikyuu/utilities/thread/GlobalMQStealThreadPool.h

@@ -232,6 +232,19 @@ class HKU_UTILS_API GlobalMQStealThreadPool {
         m_done = true;
     }
 
+    struct ExecutorWrapper {
+        GlobalMQStealThreadPool* pool;
+        template <typename Function>
+        void execute(Function f) {
+            pool->submit(std::move(f));
+        }
+    };
+
+    /** 协程执行器 */
+    ExecutorWrapper executor() {
+        return ExecutorWrapper{this};
+    }
+
 private:
     typedef FuncWrapper task_type;
     std::atomic_bool m_done;      // 线程池全局需终止指示

hikyuu_cpp/hikyuu/utilities/thread/GlobalMQThreadPool.h

@@ -223,6 +223,19 @@ class HKU_UTILS_API GlobalMQThreadPool {
         m_done = true;
     }
 
+    struct ExecutorWrapper {
+        GlobalMQThreadPool* pool;
+        template <typename Function>
+        void execute(Function f) {
+            pool->submit(std::move(f));
+        }
+    };
+
+    /** 协程执行器 */
+    ExecutorWrapper executor() {
+        return ExecutorWrapper{this};
+    }
+
 private:
     typedef FuncWrapper task_type;
     std::atomic_bool m_done;      // 线程池全局需终止指示

hikyuu_cpp/hikyuu/utilities/thread/GlobalStealThreadPool.h

@@ -15,6 +15,7 @@
 #include "ThreadSafeQueue.h"
 #include "WorkStealQueue.h"
 #include "InterruptFlag.h"
+#include "../Log.h"
 #include "../cppdef.h"
 
 #ifdef __GNUC__
@@ -281,6 +282,19 @@ class HKU_UTILS_API GlobalStealThreadPool {
         m_threads.clear();
     }
 
+    struct ExecutorWrapper {
+        GlobalStealThreadPool* pool;
+        template <typename Function>
+        void execute(Function f) {
+            pool->submit(std::move(f));
+        }
+    };
+
+    /** 协程执行器 */
+    ExecutorWrapper executor() {
+        return ExecutorWrapper{this};
+    }
+
 public:
     bool run_available_task_once() {
         HKU_IF_RETURN(m_done.load(std::memory_order_acquire) || m_thread_need_stop.isSet(), false);

hikyuu_cpp/hikyuu/utilities/thread/GlobalThreadPool.h

@@ -176,6 +176,19 @@ class HKU_UTILS_API GlobalThreadPool {
         m_master_work_queue.clear();
     }
 
+    struct ExecutorWrapper {
+        GlobalThreadPool* pool;
+        template <typename Function>
+        void execute(Function f) {
+            pool->submit(std::move(f));
+        }
+    };
+
+    /** 协程执行器 */
+    ExecutorWrapper executor() {
+        return ExecutorWrapper{this};
+    }
+
 private:
     typedef FuncWrapper task_type;
     std::atomic_bool m_done;     // 线程池全局需终止指示

hikyuu_cpp/hikyuu/utilities/thread/MQStealThreadPool.h

@@ -225,6 +225,19 @@ class HKU_UTILS_API MQStealThreadPool {
         }
     }
 
+    struct ExecutorWrapper {
+        MQStealThreadPool* pool;
+        template <typename Function>
+        void execute(Function f) {
+            pool->submit(std::move(f));
+        }
+    };
+
+    /** 协程执行器 */
+    ExecutorWrapper executor() {
+        return ExecutorWrapper{this};
+    }
+
 private:
     typedef FuncWrapper task_type;
     std::atomic_bool m_done;      // 线程池全局需终止指示

hikyuu_cpp/hikyuu/utilities/thread/MQThreadPool.h

@@ -206,6 +206,19 @@ class HKU_UTILS_API MQThreadPool {
         m_done = true;
     }
 
+    struct ExecutorWrapper {
+        MQThreadPool *pool;
+        template <typename Function>
+        void execute(Function f) {
+            pool->submit(std::move(f));
+        }
+    };
+
+    /** 协程执行器 */
+    ExecutorWrapper executor() {
+        return ExecutorWrapper{this};
+    }
+
 private:
     typedef FuncWrapper task_type;
     std::atomic_bool m_done;      // 线程池全局需终止指示

hikyuu_cpp/hikyuu/utilities/thread/StealThreadPool.h

@@ -228,6 +228,19 @@ class HKU_UTILS_API StealThreadPool {
         }
     }
 
+    struct ExecutorWrapper {
+        StealThreadPool* pool;
+        template <typename Function>
+        void execute(Function f) {
+            pool->submit(std::move(f));
+        }
+    };
+
+    /** 协程执行器 */
+    ExecutorWrapper executor() {
+        return ExecutorWrapper{this};
+    }
+
 private:
     typedef FuncWrapper task_type;
     std::atomic_bool m_done;       // 线程池全局需终止指示

hikyuu_cpp/hikyuu/utilities/thread/ThreadPool.h

@@ -170,6 +170,19 @@ class ThreadPool {
         m_master_work_queue.clear();
     }
 
+    struct ExecutorWrapper {
+        ThreadPool* pool;
+        template <typename Function>
+        void execute(Function f) {
+            pool->submit(std::move(f));
+        }
+    };
+
+    /** 协程执行器 */
+    ExecutorWrapper executor() {
+        return ExecutorWrapper{this};
+    }
+
 private:
     typedef FuncWrapper task_type;
     std::atomic_bool m_done;     // 线程池全局需终止指示