增加 releasePool 使得外部可以主动释放Pollers

src/Poller/EventPoller.cpp

@@ -642,5 +642,9 @@ void EventPollerPool::enableCpuAffinity(bool enable) {
     s_enable_cpu_affinity = enable;
 }
 
+void EventPollerPool::releasePool() {
+    releaseAllEventPooler();
+}
+
 }  // namespace toolkit
 

src/Poller/EventPoller.h

@@ -376,6 +376,8 @@ class EventPollerPool : public std::enable_shared_from_this<EventPollerPool>, pu
      */
     static void enableCpuAffinity(bool enable);
 
+    void releasePool();
+
     /**
      * 获取第一个实例
      * @return

src/Thread/TaskExecutor.cpp

@@ -227,6 +227,10 @@ size_t TaskExecutorGetterImp::getExecutorSize() const {
     return _threads.size();
 }
 
+void TaskExecutorGetterImp::releaseAllEventPooler() {
+    _threads.clear();
+}
+
 size_t TaskExecutorGetterImp::addPoller(const string &name, size_t size, int priority, bool register_thread, bool enable_cpu_affinity) {
     auto cpus = thread::hardware_concurrency();
     size = size > 0 ? size : cpus;

src/Thread/TaskExecutor.h

@@ -296,6 +296,8 @@ class TaskExecutorGetterImp : public TaskExecutorGetter {
      */
     size_t getExecutorSize() const override;
 
+    void releaseAllEventPooler();
+
 protected:
     size_t addPoller(const std::string &name, size_t size, int priority, bool register_thread, bool enable_cpu_affinity = true);