mirrors/spdlog
1
0
Fork 0
mirror of https://github.com/gabime/spdlog.git synced 2025-03-01 03:35:50 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Small clean of enqueue_if_have_room in mpmc_blocking_q.h

Browse Source
This commit is contained in:
gabime 2025-01-18 16:04:31 +02:00
parent 214e26e8b2
commit af8440b248
1 changed files with 6 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
include/spdlog/details/mpmc_blocking_q.h
View File

@ -47,20 +47,15 @@ public:
} }
void enqueue_if_have_room(T &&item) { void enqueue_if_have_room(T &&item) {
bool pushed = false;
{ {
std::unique_lock<std::mutex> lock(queue_mutex_); std::unique_lock lock(queue_mutex_);
if (!q_.full()) { if (q_.full()) {
q_.push_back(std::move(item)); ++discard_counter_;
pushed = true; return;
} }
q_.push_back(std::move(item));
} }
push_cv_.notify_one();
if (pushed) {
push_cv_.notify_one();
} else {
++discard_counter_;
}
} }
// dequeue with a timeout. // dequeue with a timeout.