[bugfix] fix notify sleep 1s bug

Author: ChunelFeng

src/UtilsCtrl/ThreadPool/Queue/UWorkStealingQueue.h

@@ -169,6 +169,15 @@ class UWorkStealingQueue : public UQueueObject {
         return result;    // 如果非空，表示盗取成功
     }
 
+
+    /**
+     * 判断当前队列是否为空
+     * @return
+     */
+    CBool isEmpty() const {
+        return deque_.empty();
+    }
+
     UWorkStealingQueue() = default;
 
     CGRAPH_NO_ALLOWED_COPY(UWorkStealingQueue)

src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h

@@ -114,12 +114,12 @@ class UThreadPrimary : public UThreadBase {
      * 休眠一定时间后，然后恢复执行状态，避免出现异常情况导致无法唤醒
      */
     CVoid fatWait() {
-        cur_empty_epoch_++;
+        ++cur_empty_epoch_;
         CGRAPH_YIELD();
         if (cur_empty_epoch_ >= config_->primary_thread_busy_epoch_) {
             CGRAPH_UNIQUE_LOCK lk(mutex_);
             cv_.wait_for(lk, std::chrono::milliseconds(config_->primary_thread_empty_interval_),
-                         [this] { return 0 == cur_empty_epoch_; });
+                         [this] { return 0 == cur_empty_epoch_ || !wsq_.isEmpty(); });
             cur_empty_epoch_ = 0;
         }
     }
@@ -131,9 +131,7 @@ class UThreadPrimary : public UThreadBase {
      * @return
      */
     CVoid pushTask(UTask&& task) {
-        while (!wsq_.tryPush(std::move(task))) {
-            CGRAPH_YIELD();
-        }
+        wsq_.push(std::move(task));
         {
             CGRAPH_LOCK_GUARD lk(mutex_);
             cur_empty_epoch_ = 0;
@@ -257,7 +255,7 @@ class UThreadPrimary : public UThreadBase {
 
 private:
     CInt index_ {0};                                                  // 线程index
-    std::atomic<CInt> cur_empty_epoch_ {0};                           // 当前空转的轮数信息
+    std::atomic<CInt> cur_empty_epoch_ {0 };                       // 当前空转的轮数信息
     UWorkStealingQueue<UTask> wsq_ {};                                // 内部队列信息
     std::vector<UThreadPrimary *>* pool_threads_ {};                  // 用于存放线程池中的线程信息
     std::vector<CInt> steal_targets_ {};                              // 被偷的目标信息

src/UtilsCtrl/ThreadPool/UThreadPoolDefine.h

@@ -53,7 +53,7 @@ static const CBool CGRAPH_BATCH_TASK_ENABLE = false;
 static const CInt CGRAPH_MAX_LOCAL_BATCH_SIZE = 2;                                           // 批量执行本地任务最大值
 static const CInt CGRAPH_MAX_POOL_BATCH_SIZE = 2;                                            // 批量执行通用任务最大值
 static const CInt CGRAPH_MAX_STEAL_BATCH_SIZE = 2;                                           // 批量盗取任务最大值
-static const CInt CGRAPH_PRIMARY_THREAD_BUSY_EPOCH = 5;                                      // 主线程进入wait状态的轮数，数值越大，理论性能越高，但空转可能性也越大
+static const CInt CGRAPH_PRIMARY_THREAD_BUSY_EPOCH = 3;                                      // 主线程进入wait状态的轮数，数值越大，理论性能越高，但空转可能性也越大
 static const CMSec CGRAPH_PRIMARY_THREAD_EMPTY_INTERVAL = 1000;                              // 主线程进入休眠状态的默认时间
 static const CSec CGRAPH_SECONDARY_THREAD_TTL = 10;                                          // 辅助线程ttl，单位为s
 static const CBool CGRAPH_MONITOR_ENABLE = false;                                            // 是否开启监控程序