我正在嘗試制作一個多執行緒函式，它看起來像：
namespace { // Anonymous namespace instead of static functions.
std::mutex log_mutex;
void Background() {
while(IsAlive){
std::queue<std::string> log_records;
{
// Exchange data for minimizing lock time.
std::unique_lock lock(log_mutex);
logs.swap(log_records);
}
if (log_records.empty()) {
Sleep(200);
continue;
}
while(!log_records.empty()){
ShowLog(log_records.front());
log_records.pop();
}
}
}
void Log(std::string log){
std::unique_lock lock(log_mutex);
logs.push(std::move(log));
}
}
即使日志為空，我也會使用 Sleep 來防止由于連續回圈而導致 CPU 使用率過高。但這有一個非常明顯的缺點，它將批量列印日志。我試圖通過使用條件變數來解決這個問題，但問題是如果在短時間內有太多日志，那么 cv 會停止并多次喚醒，導致 CPU 使用率更高。現在我能做些什么來解決這個問題？您可以假設每秒可能有很多呼叫記錄。
uj5u.com熱心網友回復：
我可能會考慮為此使用計數信號量：
- 信號量將記錄日志中的訊息數（最初為零）。
- 日志客戶端將寫入一條訊息并通過釋放信號量將訊息數量增加一。
- 日志服務器將對信號量進行獲取，阻塞直到日志中有任何訊息，然后將訊息數量減一。
注意：
- 日志客戶端獲得
logs佇列鎖，推送訊息，然后才對信號量進行釋放。 - 日志服務器可以在獲取
logs佇列鎖之前進行獲取；即使有更多的讀者，這也是可能的。例如：日志佇列中有 1 條訊息，服務器 1 進行獲取，服務器 2 進行獲取并阻塞，因為信號量計數為 0，服務器 1 繼續并獲取logs佇列鎖......
#include <algorithm> // for_each
#include <chrono> // chrono_literasl
#include <future> // async, future
#include <iostream> // cout
#include <mutex> // mutex, unique_lock
#include <queue>
#include <semaphore> // counting_semaphore
#include <string>
#include <thread> // sleep_for
#include <vector>
std::mutex mtx{};
std::queue<std::string> logs{};
std::counting_semaphore c_semaphore{ 0 };
int main()
{
auto log = [](std::string message) {
std::unique_lock lock{ mtx };
logs.push(std::move(message));
c_semaphore.release();
};
auto log_client = [&log]() {
using namespace std::chrono_literals;
static size_t s_id{ 1 };
size_t id{ s_id };
for (;;)
{
log(std::to_string(id));
std::this_thread::sleep_for(id * 100ms);
}
};
auto log_server = []() {
for (;;)
{
c_semaphore.acquire();
std::unique_lock lock{ mtx };
std::cout << logs.front() << " ";
logs.pop();
}
};
std::vector<std::future<void>> log_clients(10);
std::for_each(std::begin(log_clients), std::end(log_clients),
[&log_client](auto& lc_fut) {
lc_fut = std::async(std::launch::async, log_client);
});
auto ls_fut{ std::async(std::launch::async, log_server) };
std::for_each(std::begin(log_clients), std::end(log_clients),
[](auto& lc_fut) { lc_fut.wait(); });
ls_fut.wait();
}
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/407124.html
標籤：