thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-04 21:42:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

Try abort on current thread join.

Browse Source
This commit is contained in:
Nikolai Kochetov 2022-10-21 10:05:25 +00:00
parent ad3b324382
commit 2ddc55a92a
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/Common/ThreadPool.h
View File

@ -178,7 +178,10 @@ public:
func = std::forward<Function>(func),
args = std::make_tuple(std::forward<Args>(args)...)]() mutable /// mutable is needed to destroy capture
{
SCOPE_EXIT(state->event.set());
SCOPE_EXIT(
state->thread_id = std::thread::id();
state->event.set();
);
state->thread_id = std::this_thread::get_id();