修复adminRegistry线程过多

lorgine-li · Oct 26, 2017 · bd8ac1f · bd8ac1f
1 parent 9e8f03a
commit bd8ac1f
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/cpp/framework/AdminRegistryServer/ExecuteTask.cpp b/cpp/framework/AdminRegistryServer/ExecuteTask.cpp
@@ -424,11 +424,20 @@ void TaskListParallel::doTask(TaskItemReq req, size_t index)
 
 ExecuteTask::ExecuteTask()
 {
+    _terminate = false;
+    start();
 }
 
 ExecuteTask::~ExecuteTask()
+{
+    terminate();
+}
+
+void ExecuteTask::terminate()
 {
     _terminate = true;
+    TC_LockT<TC_ThreadLock> lock(*this);
+    notifyAll();
 }
 
 void ExecuteTask::run()

diff --git a/cpp/framework/AdminRegistryServer/ExecuteTask.h b/cpp/framework/AdminRegistryServer/ExecuteTask.h
@@ -108,6 +108,8 @@ class ExecuteTask : public TC_Singleton<ExecuteTask>, public TC_ThreadLock, publ
 
     virtual void run();
 
+    void terminate();
+
     /**
      * 添加任务请求
      *