From 6b96ee857e366af317ab9dc1b6b4f9c22576e83b Mon Sep 17 00:00:00 2001
From: lichao <lichao@aiotlink.com>
Date: 星期四, 20 五月 2021 17:12:34 +0800
Subject: [PATCH] add sleeper, to reduce cpu usage.
---
src/shm_socket.cpp | 8 +++++++-
1 files changed, 7 insertions(+), 1 deletions(-)
diff --git a/src/shm_socket.cpp b/src/shm_socket.cpp
index 4b687d5..f177b87 100644
--- a/src/shm_socket.cpp
+++ b/src/shm_socket.cpp
@@ -20,7 +20,9 @@
#include "bh_util.h"
#include "defs.h"
#include "msg.h"
+#include "sleeper.h"
#include <chrono>
+
using namespace std::chrono;
using namespace std::chrono_literals;
@@ -90,11 +92,15 @@
};
try {
+ thread_local FibUSleeper sleeper(1000 * 10);
+
bool more_to_send = DoSend();
bool more_to_recv = DoRecv();
if (onIdle) { onIdle(*this); }
if (!more_to_send && !more_to_recv) {
- robust::QuickSleep();
+ sleeper.Sleep();
+ } else {
+ sleeper.Reset();
}
} catch (...) {
}
--
Gitblit v1.8.0