xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

[TD-225] fix compiler error.

This commit is contained in:
Haojun Liao 2020-12-10 10:44:04 +08:00
parent 7e84d868d9
commit 434aefb880
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/util/src/tworker.c
View File

@ -36,14 +36,14 @@ int32_t tWorkerInit(SWorkerPool *pPool) {
void tWorkerCleanup(SWorkerPool *pPool) { void tWorkerCleanup(SWorkerPool *pPool) {
for (int i = 0; i < pPool->max; ++i) { for (int i = 0; i < pPool->max; ++i) {
SWorker *pWorker = pPool->worker + i; SWorker *pWorker = pPool->worker + i;
if (pWorker->thread != 0) { if(taosCheckPthreadValid(pWorker->thread)) {
taosQsetThreadResume(pPool->qset); taosQsetThreadResume(pPool->qset);
} }
} }
for (int i = 0; i < pPool->max; ++i) { for (int i = 0; i < pPool->max; ++i) {
SWorker *pWorker = pPool->worker + i; SWorker *pWorker = pPool->worker + i;
if (pWorker->thread != 0) { if (taosCheckPthreadValid(pWorker->thread)) {
pthread_join(pWorker->thread, NULL); pthread_join(pWorker->thread, NULL);
} }
} }