From fc9d1afd60619d55d7820afb704b778d02b6d83c Mon Sep 17 00:00:00 2001 From: Chunel Date: Sun, 19 Apr 2026 13:22:54 +0800 Subject: [PATCH] [doc] optimize some annotation --- example/E05-HttpServer.cpp | 1 - src/UtilsCtrl/ThreadPool/UThreadPool.h | 4 ++-- 2 files changed, 2 insertions(+), 3 deletions(-) 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_; // 用于记录所有的辅助线程