diff --git a/example/E05-HttpServer.cpp b/example/E05-HttpServer.cpp index d127e8db..68786395 100644 --- a/example/E05-HttpServer.cpp +++ b/example/E05-HttpServer.cpp @@ -42,7 +42,6 @@ class ProcessNode : public GNode { CStatus run() override { auto param = CGRAPH_GET_GPARAM_WITH_NO_EMPTY(HttpParam, EXAMPLE_PARAM_KEY); { - // 从这里可以看出来,manager 中的每个pipeline,实际上都是 CGRAPH_PARAM_WRITE_CODE_BLOCK(param); CGRAPH_ECHO("process step %d, sleep %d ms, val is %d, loop is %d", STEP, MS, ++param->val_, ++param->loop_); diff --git a/src/UtilsCtrl/ThreadPool/UThreadPool.h b/src/UtilsCtrl/ThreadPool/UThreadPool.h index 800ca1e8..d51bb61b 100644 --- a/src/UtilsCtrl/ThreadPool/UThreadPool.h +++ b/src/UtilsCtrl/ThreadPool/UThreadPool.h @@ -199,8 +199,8 @@ class UThreadPool : public UThreadObject { private: CBool is_init_ { false }; // 是否初始化 - std::atomic cur_index_ { 0 }; // 记录放入的线程数 - UAtomicQueue task_queue_; // 用于存放普通任务 + std::atomic cur_index_ { 0 }; // 记录被轮询到的线程index的位置 + UAtomicQueue task_queue_ {}; // 用于存放普通任务 UAtomicPriorityQueue priority_task_queue_; // 运行时间较长的任务队列,仅在辅助线程中执行 std::vector primary_threads_; // 记录所有的主线程 std::list> secondary_threads_; // 用于记录所有的辅助线程