mirrors/spdlog
1
0
Fork 0
mirror of https://github.com/gabime/spdlog.git synced 2024-12-26 10:31:34 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

async_helper sleep_or_yield or full/empty queue

Browse Source
This commit is contained in:
gabi 2014-12-03 00:28:33 +02:00
parent 01344b6c8b
commit 3916674bc5
1 changed files with 36 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
include/spdlog/details/async_log_helper.h
View File

@ -125,8 +125,8 @@ private:
// worker thread loop // worker thread loop
void _thread_loop(); void _thread_loop();
// guess how much to sleep if queue is empty // guess how much to sleep if queue is empty/full using last succesful op time as hint
static clock::duration spdlog::details::async_log_helper::_calc_pop_sleep(const clock::time_point& last_pop); static void _sleep_or_yield(const clock::time_point& last_op_time);
// clear all remaining messages(if any), stop the _worker_thread and join it // clear all remaining messages(if any), stop the _worker_thread and join it
@ -151,11 +151,22 @@ inline spdlog::details::async_log_helper::~async_log_helper()
_join(); _join();
} }
//Try to push and block until succeeded
inline void spdlog::details::async_log_helper::log(const details::log_msg& msg) inline void spdlog::details::async_log_helper::log(const details::log_msg& msg)
{ {
_push_sentry(); _push_sentry();
_q.push(std::unique_ptr<async_msg>(new async_msg(msg))); //Only if queue is full, enter wait loop
if (!_q.push(std::unique_ptr < async_msg >(new async_msg(msg))))
{
auto last_op_time = clock::now();
do
{
_sleep_or_yield(last_op_time);
}
while (!_q.push(std::unique_ptr < async_msg >(new async_msg(msg))));
}
} }
inline void spdlog::details::async_log_helper::_thread_loop() inline void spdlog::details::async_log_helper::_thread_loop()
@ -189,30 +200,14 @@ inline void spdlog::details::async_log_helper::_thread_loop()
_last_workerthread_ex = std::make_shared<spdlog_ex>("Unknown exception"); _last_workerthread_ex = std::make_shared<spdlog_ex>("Unknown exception");
} }
} }
//Sleep for a while if empty. // sleep or yield if queue is empty.
else else
{ {
std::this_thread::sleep_for(_calc_pop_sleep(last_pop)); _sleep_or_yield(last_pop);
} }
} }
} }
//Try to guess sleep duration according to the time passed since last message
inline spdlog::details::async_log_helper::clock::duration spdlog::details::async_log_helper::_calc_pop_sleep(const clock::time_point& last_pop)
{
using std::chrono::milliseconds;
using std::chrono::microseconds;
auto time_since_pop = clock::now() - last_pop;
if (time_since_pop > milliseconds(1000))
return milliseconds(500);
if (time_since_pop > microseconds(0))
return(time_since_pop / 2);
return microseconds(0);
}
inline void spdlog::details::async_log_helper::add_sink(spdlog::sink_ptr s) inline void spdlog::details::async_log_helper::add_sink(spdlog::sink_ptr s)
{ {
@ -249,6 +244,23 @@ inline void spdlog::details::async_log_helper::shutdown(const log_clock::duratio
} }
// Sleep or yield using the time passed since last message as a hint
inline void spdlog::details::async_log_helper::_sleep_or_yield(const clock::time_point& last_op_time)
{
using std::chrono::milliseconds;
using std::this_thread::sleep_for;
using std::this_thread::yield;
clock::duration sleep_duration;
auto time_since_op = clock::now() - last_op_time;
if (time_since_op > milliseconds(1000))
sleep_for(milliseconds(500));
else if (time_since_op > milliseconds(1))
sleep_for(time_since_op / 2);
else
yield();
}
inline void spdlog::details::async_log_helper::_push_sentry() inline void spdlog::details::async_log_helper::_push_sentry()
{ {
if (_last_workerthread_ex) if (_last_workerthread_ex)
@ -278,3 +290,6 @@ inline void spdlog::details::async_log_helper::_join()
} }