thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-29 11:02:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

Try to fix race in PipelineExecutor.

Browse Source
This commit is contained in:
Nikolai Kochetov 2019-09-09 20:56:58 +03:00
parent 423a5c35e8
commit eeba24b238
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dbms/src/Processors/Executors/PipelineExecutor.cpp
View File

@ -498,8 +498,8 @@ void PipelineExecutor::executeSingleThread(size_t thread_num, size_t num_threads
if (!task_queue.empty() && !threads_queue.empty())
{
auto thread_to_wake = threads_queue.top();
threads_queue.pop();
auto thread_to_wake = *threads_queue.begin();
threads_queue.erase(threads_queue.begin());
--num_waiting_threads;
lock.unlock();
@ -520,7 +520,7 @@ void PipelineExecutor::executeSingleThread(size_t thread_num, size_t num_threads
break;
}
threads_queue.push(thread_num);
threads_queue.insert(thread_num);
}
{