From a3accab0538cba2bd91416d35941efc4be56d2f7 Mon Sep 17 00:00:00 2001
From: Chunel <Chunel@foxmail.com>
Date: Fri, 3 Jul 2026 23:29:21 +0800
Subject: [PATCH] [perf] change some atomic memory order

---
 .../GraphElement/GAdapter/GSingleton/GSingleton.inl       | 8 ++++----
 src/GraphCtrl/GraphElement/GElement.cpp                   | 4 ++--
 src/UtilsCtrl/ThreadPool/Lock/USpinLock.h                 | 2 +-
 src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h             | 6 +++---
 src/UtilsCtrl/Timer/UTimer.h                              | 8 ++++----
 5 files changed, 14 insertions(+), 14 deletions(-)

diff --git a/src/GraphCtrl/GraphElement/GAdapter/GSingleton/GSingleton.inl b/src/GraphCtrl/GraphElement/GAdapter/GSingleton/GSingleton.inl
index 7e46fdfa..c4369fed 100644
--- a/src/GraphCtrl/GraphElement/GAdapter/GSingleton/GSingleton.inl
+++ b/src/GraphCtrl/GraphElement/GAdapter/GSingleton/GSingleton.inl
@@ -31,7 +31,7 @@ template <typename T>
 CStatus GSingleton<T>::init() {
     CGRAPH_FUNCTION_BEGIN
     /* 确保仅 GSingletonNode 类型内容，init一次 */
-    if (s_is_init_) {
+    if (s_is_init_.load(std::memory_order_acquire)) {
         CGRAPH_FUNCTION_END
     }
 
@@ -39,7 +39,7 @@ CStatus GSingleton<T>::init() {
     auto element = dynamic_cast<T *>(s_singleton_.get());
     status = element->init();
     if (status.isOK()) {
-        s_is_init_ = true;
+        s_is_init_.store(true, std::memory_order_release);
     }
 
     CGRAPH_FUNCTION_END
@@ -59,14 +59,14 @@ CStatus GSingleton<T>::run() {
 template <typename T>
 CStatus GSingleton<T>::destroy() {
     CGRAPH_FUNCTION_BEGIN
-    if (!s_is_init_) {
+    if (!s_is_init_.load(std::memory_order_acquire)) {
         CGRAPH_FUNCTION_END
     }
 
     auto element = dynamic_cast<T *>(s_singleton_.get());
     status = element->destroy();
     if (status.isOK()) {
-        s_is_init_ = false;
+        s_is_init_.store(false, std::memory_order_release);
     }
 
     CGRAPH_FUNCTION_END
diff --git a/src/GraphCtrl/GraphElement/GElement.cpp b/src/GraphCtrl/GraphElement/GElement.cpp
index cb35007c..bad066ef 100644
--- a/src/GraphCtrl/GraphElement/GElement.cpp
+++ b/src/GraphCtrl/GraphElement/GElement.cpp
@@ -23,8 +23,8 @@ GElement::~GElement() {
 
 
 CVoid GElement::refresh() {
-    this->done_ = false;
-    this->left_depend_.store(dependence_.size(), std::memory_order_release);
+    this->done_.store(false, std::memory_order_relaxed);
+    this->left_depend_.store(dependence_.size(), std::memory_order_relaxed);
 }
 
 
diff --git a/src/UtilsCtrl/ThreadPool/Lock/USpinLock.h b/src/UtilsCtrl/ThreadPool/Lock/USpinLock.h
index 1615f9be..85f4c53a 100644
--- a/src/UtilsCtrl/ThreadPool/Lock/USpinLock.h
+++ b/src/UtilsCtrl/ThreadPool/Lock/USpinLock.h
@@ -39,7 +39,7 @@ class USpinLock : public UThreadObject {
      * @return
      */
     CBool tryLock() {
-        return !flag_.test_and_set();
+        return !flag_.test_and_set(std::memory_order_acquire);
     }
 
 private:
diff --git a/src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h b/src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h
index 6b14b52f..c0350385 100644
--- a/src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h
+++ b/src/UtilsCtrl/ThreadPool/Thread/UThreadBase.h
@@ -24,7 +24,7 @@ class UThreadBase : public UThreadObject {
     explicit UThreadBase() {
         done_ = true;
         is_init_ = false;
-        is_running_ = false;
+        is_running_.store(false, std::memory_order_relaxed);
         pool_task_queue_ = nullptr;
         pool_priority_task_queue_ = nullptr;
         config_ = nullptr;
@@ -113,7 +113,7 @@ class UThreadBase : public UThreadObject {
             thread_.join();    // 等待线程结束
         }
         is_init_ = false;
-        is_running_ = false;
+        is_running_.store(false, std::memory_order_relaxed);
         total_task_num_ = 0;
     }
 
@@ -151,7 +151,7 @@ class UThreadBase : public UThreadObject {
      */
     CVoid loopProcess() {
         CGRAPH_ASSERT_NOT_NULL_THROW_ERROR(config_)
-        is_running_ = true;
+        is_running_.store(true, std::memory_order_relaxed);
         if (config_->batch_task_enable_) {
             while (done_) {
                 processTasks();    // 批量任务获取执行接口
diff --git a/src/UtilsCtrl/Timer/UTimer.h b/src/UtilsCtrl/Timer/UTimer.h
index f85c715d..3f4f9e82 100644
--- a/src/UtilsCtrl/Timer/UTimer.h
+++ b/src/UtilsCtrl/Timer/UTimer.h
@@ -31,7 +31,7 @@ class UTimer : public UtilsObject {
      */
     template<typename TTask, typename TMod>
     CVoid start(CMSec interval, const TTask& task, const TMod& modify) {
-        if (!is_stop_.exchange(false)) {
+        if (!is_stop_.exchange(false, std::memory_order_relaxed)) {
             return;    // 如果正在执行中，则无法继续执行
         }
 
@@ -43,10 +43,10 @@ class UTimer : public UtilsObject {
          * std::launch::deferred：延迟加载方式创建线程。调用async时不创建线程，直到调用了future的get或者wait时才创建线程。
          */
         future_ = std::async(std::launch::async, [this, task, modify]() {
-             while (!is_stop_) {
+             while (!is_stop_.load(std::memory_order_relaxed)) {
                  CGRAPH_UNIQUE_LOCK lk(mutex_);
                  auto result = cv_.wait_for(lk, std::chrono::milliseconds(left_interval_));
-                 if (std::cv_status::timeout == result && !is_stop_) {
+                 if (std::cv_status::timeout == result && !is_stop_.load(std::memory_order_relaxed)) {
                      CMSec start = CGRAPH_GET_CURRENT_MS();
                      task();
                      CMSec ms = modify();
@@ -75,7 +75,7 @@ class UTimer : public UtilsObject {
      * 关闭定时器
      */
     CVoid stop() {
-        if (is_stop_.exchange(true)) {
+        if (is_stop_.exchange(true, std::memory_order_relaxed)) {
             return;
         }