hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix thread hang when os oom

Browse Source
This commit is contained in:
nroskill
2024-01-05 05:43:05 +00:00
committed by ob-robot
parent 6ef2d82735
commit 080a8aded1
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
deps/oblib/src/lib/thread/thread.cpp vendored
View File

@ -99,14 +99,16 @@ int Thread::start()
if (pret == 0) { if (pret == 0) {
stop_ = false; stop_ = false;
pret = pthread_create(&pth_, &attr, __th_start, this); pret = pthread_create(&pth_, &attr, __th_start, this);
while (ATOMIC_LOAD(&create_ret_) == OB_NOT_RUNNING) {
sched_yield();
}
if (pret != 0) { if (pret != 0) {
LOG_ERROR("pthread create failed", K(pret), K(errno)); LOG_ERROR("pthread create failed", K(pret), K(errno));
pth_ = 0; pth_ = 0;
} else if (OB_FAIL(create_ret_)) { } else {
LOG_ERROR("thread create failed", K(create_ret_)); while (ATOMIC_LOAD(&create_ret_) == OB_NOT_RUNNING) {
sched_yield();
}
if (OB_FAIL(create_ret_)) {
LOG_ERROR("thread create failed", K(create_ret_));
}
} }
} }
if (0 != pret) { if (0 != pret) {
@ -346,6 +348,9 @@ void* Thread::__th_start(void *arg)
} }
} }
} }
if (OB_FAIL(ret)) {
ATOMIC_STORE(&th->create_ret_, ret);
}
ATOMIC_FAA(&total_thread_count_, -1); ATOMIC_FAA(&total_thread_count_, -1);
return nullptr; return nullptr;
} }