diff --git a/src/util/src/tworker.c b/src/util/src/tworker.c
index 46d02273f3bec1301f98ebcc066b511b7af43466..a45e73d4c6f9c1d990845ee765f7faed457b5ff5 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) {
+    if (pWorker->thread != 0) {
       taosQsetThreadResume(pPool->qset);
     }
   }
 
   for (int i = 0; i < pPool->max; ++i) {
     SWorker *pWorker = pPool->worker + i;
-    if (pWorker->thread) {
+    if (pWorker->thread != 0) {
       pthread_join(pWorker->thread, NULL);
     }
   }