gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

counter for time thread sleeping threads

Browse Source 
Former-commit-id: 6270939d6a2d7820fecac9c5aedf0ff985531f6b
This commit is contained in:
christianEQ 2021-03-24 20:33:26 +00:00
parent 22cffc5d54
commit 6d1be2a3f5
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/server.cpp
View File

@ -100,7 +100,7 @@ thread_local struct redisServerThreadVars *serverTL = NULL; // thread local se
volatile unsigned long lru_clock; /* Server global current LRU time. */ volatile unsigned long lru_clock; /* Server global current LRU time. */
std::mutex time_thread_mutex; std::mutex time_thread_mutex;
std::condition_variable time_thread_cv; std::condition_variable time_thread_cv;
bool time_thread_running = false; int sleeping_threads = cserver.cthreads;
void wakeTimeThread(); void wakeTimeThread();
/* Our command table. /* Our command table.
@ -2514,7 +2514,9 @@ void beforeSleep(struct aeEventLoop *eventLoop) {
serverAssert(g_pserver->repl_batch_offStart < 0); serverAssert(g_pserver->repl_batch_offStart < 0);
runAndPropogateToReplicas(processClients); runAndPropogateToReplicas(processClients);
time_thread_running = false; time_thread_mutex.lock();
sleeping_threads++;
time_thread_mutex.unlock();
/* Handle precise timeouts of blocked clients. */ /* Handle precise timeouts of blocked clients. */
handleBlockedClientsTimeout(); handleBlockedClientsTimeout();
@ -6086,7 +6088,9 @@ void OnTerminate()
} }
void wakeTimeThread() { void wakeTimeThread() {
time_thread_running = true; time_thread_mutex.lock();
sleeping_threads--;
time_thread_mutex.unlock();
time_thread_cv.notify_one(); time_thread_cv.notify_one();
} }
@ -6096,7 +6100,7 @@ void *timeThreadMain(void*) {
delay.tv_nsec = 100; delay.tv_nsec = 100;
while (true) { while (true) {
std::unique_lock<std::mutex> lock(time_thread_mutex); std::unique_lock<std::mutex> lock(time_thread_mutex);
if (!time_thread_running) { if (sleeping_threads >= cserver.cthreads) {
time_thread_cv.wait(lock); time_thread_cv.wait(lock);
} }
updateCachedTime(); updateCachedTime();