diff --git a/README.md b/README.md index 35b1c866..af97ec1a 100644 --- a/README.md +++ b/README.md @@ -168,6 +168,7 @@ if __name__ == '__main__': * [CGraph作者想知道,您是否需要一款eDAG调度框架](http://www.chunel.cn/archives/cgraph-extended-dag) * [降边增效:CGraph中冗余边剪裁思路总结](http://www.chunel.cn/archives/cgraph-remove-redundancy-link) * [最新码坛爽文:重生之我在国外写CGraph(python版本)](http://www.chunel.cn/archives/cgraph-pycgraph-v1) +* [做之前不敢想的 CGraph](http://www.chunel.cn/archives/cgraph-unbelievable-2025)
---- diff --git a/src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h b/src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h index 9da7807c..abe5d995 100644 --- a/src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h +++ b/src/UtilsCtrl/ThreadPool/Thread/UThreadPrimary.h @@ -116,7 +116,7 @@ class UThreadPrimary : public UThreadBase { CVoid fatWait() { ++cur_empty_epoch_; CGRAPH_YIELD(); - if (cur_empty_epoch_ >= config_->primary_thread_busy_epoch_ && wsq_.isEmpty()) { + 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_ || !wsq_.isEmpty() || !done_; });