From 0efae716cdd334d86dc9c9edbd15c8a664f8849b Mon Sep 17 00:00:00 2001 From: anulax1225 Date: Mon, 24 Feb 2025 02:22:27 +0100 Subject: [PATCH] Update of code --- src/bakatools/logging/log.cpp | 2 +- src/bakatools/thread/task_pool.h | 3 +++ 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/src/bakatools/logging/log.cpp b/src/bakatools/logging/log.cpp index 09b57a2..62b96f8 100644 --- a/src/bakatools/logging/log.cpp +++ b/src/bakatools/logging/log.cpp @@ -9,7 +9,7 @@ namespace Bk { { std::vector log_sinks; log_sinks.emplace_back(std::make_shared()); - log_sinks[0]->set_pattern("%^[%T] %n: %v%$"); + log_sinks[0]->set_pattern("%^[%T] %n(thread %t) %v%$"); if (file_log) { log_sinks.emplace_back(std::make_shared("bakara.log", true)); diff --git a/src/bakatools/thread/task_pool.h b/src/bakatools/thread/task_pool.h index 785e9d4..8ce7c81 100644 --- a/src/bakatools/thread/task_pool.h +++ b/src/bakatools/thread/task_pool.h @@ -19,6 +19,7 @@ namespace Bk threads_.emplace_back([this] { while (true) { std::function task; + { std::unique_lock lock(queue_mutex_); cv_.wait(lock, [this] { @@ -32,6 +33,7 @@ namespace Bk task = std::move(tasks_.front()); tasks_.pop(); } + task(); } }); @@ -65,6 +67,7 @@ namespace Bk { std::unique_lock lock(queue_mutex_); stop_ = true; + cv_.notify_one(); } private: