From 32f88c83537c1b69322a953cee75019c38b5f698 Mon Sep 17 00:00:00 2001
From: mutouyun <orz@orzz.org>
Date: Sun, 20 Sep 2020 15:30:19 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BE=AE=E8=B0=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 demo/msg_que/main.cpp | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/demo/msg_que/main.cpp b/demo/msg_que/main.cpp
index 79b5433..1f40058 100644
--- a/demo/msg_que/main.cpp
+++ b/demo/msg_que/main.cpp
@@ -21,7 +21,7 @@ constexpr std::size_t const min_sz = 128;
 constexpr std::size_t const max_sz = 1024 * 16;
 
 std::atomic<bool> is_quit__{ false };
-std::atomic<std::size_t> size_per_1s__{ 0 };
+std::atomic<std::size_t> size_counter__{ 0 };
 
 using msg_que_t = ipc::chan<ipc::relat::single, ipc::relat::single, ipc::trans::unicast>;
 
@@ -49,9 +49,8 @@ void do_counting() {
         if (i % 10) continue;
         i = 0;
         std::cout
-            << speed_of(size_per_1s__.load(std::memory_order_acquire))
+            << speed_of(size_counter__.exchange(0, std::memory_order_relaxed))
             << std::endl;
-        size_per_1s__.store(0, std::memory_order_release);
     }
 }
 
@@ -76,7 +75,7 @@ void do_send() {
                     break;
                 }
             }
-            size_per_1s__.fetch_add(sz, std::memory_order_release);
+            size_counter__.fetch_add(sz, std::memory_order_relaxed);
             std::this_thread::yield();
         }
         counting.join();
@@ -97,7 +96,7 @@ void do_recv() {
         while (!is_quit__.load(std::memory_order_acquire)) {
             auto msg = que__.recv();
             if (msg.empty()) break;
-            size_per_1s__.fetch_add(msg.size(), std::memory_order_release);
+            size_counter__.fetch_add(msg.size(), std::memory_order_relaxed);
         }
         counting.join();
     }