diff --git a/src/util/src/tworker.c b/src/util/src/tworker.c
index a45e73d4c6f9c1d990845ee765f7faed457b5ff5..8b4053bccd1ce8d9d3f58328d838f4ba5132a100 100644
--- a/src/util/src/tworker.c
+++ b/src/util/src/tworker.c
@@ -36,14 +36,14 @@ int32_t tWorkerInit(SWorkerPool *pPool) {
 void tWorkerCleanup(SWorkerPool *pPool) {
   for (int i = 0; i < pPool->max; ++i) {
     SWorker *pWorker = pPool->worker + i;
-    if (pWorker->thread != 0) {
+    if(taosCheckPthreadValid(pWorker->thread)) {
       taosQsetThreadResume(pPool->qset);
     }
   }
 
   for (int i = 0; i < pPool->max; ++i) {
     SWorker *pWorker = pPool->worker + i;
-    if (pWorker->thread != 0) {
+    if (taosCheckPthreadValid(pWorker->thread)) {
       pthread_join(pWorker->thread, NULL);
     }
   }