thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-17 21:24:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

Reduce the number of lock releases and reacquires in the BckSchPoolDelay thread

Browse Source
This commit is contained in:
Silviu Caragea 2018-03-27 16:29:41 +03:00
parent 1418e339e4
commit 0a057695aa
1 changed files with 29 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
dbms/src/Common/BackgroundSchedulePool.cpp
View File

@ -258,38 +258,46 @@ void BackgroundSchedulePool::delayExecutionThreadFunction()
while (!shutdown)
{
TaskHandle task;
bool found = false;
{
std::unique_lock lock(delayed_tasks_lock);
if(shutdown)
break;
Poco::Timestamp min_time;
if (!delayed_tasks.empty())
while(!shutdown)
{
auto t = delayed_tasks.begin();
min_time = t->first;
task = t->second;
}
Poco::Timestamp min_time;
if (!task)
{
wakeup_cond.wait(lock);
continue;
}
if (!delayed_tasks.empty())
{
auto t = delayed_tasks.begin();
min_time = t->first;
task = t->second;
}
Poco::Timestamp current_time;
if (!task)
{
wakeup_cond.wait(lock);
continue;
}
if (min_time > current_time)
{
wakeup_cond.wait_for(lock, std::chrono::microseconds(min_time - current_time));
continue;
Poco::Timestamp current_time;
if (min_time > current_time)
{
wakeup_cond.wait_for(lock, std::chrono::microseconds(min_time - current_time));
continue;
}
else
{
/// We have a task ready for execution
found = true;
break;
}
}
}
task->schedule();
if(found)
task->schedule();
}
}