yiguolei commented on code in PR #45614:
URL: https://github.com/apache/doris/pull/45614#discussion_r1891591020
##########
be/src/pipeline/pipeline_task.h:
##########
@@ -187,15 +166,26 @@ class PipelineTask {
*/
static bool should_revoke_memory(RuntimeState* state, int64_t
revocable_mem_bytes);
- void put_in_runnable_queue() {
+ bool put_in_runnable_queue(bool eager) {
+ bool expected = false;
+ if (!_in_eager_queue.compare_exchange_strong(expected, eager)) {
Review Comment:
我觉得，我们的标记位，不是这个task 是否在eager queue，
在put的时候，应该是可以随意放的。
应该是在task 运行阶段的时候，控制task 别有两个线程同时do work 就可以了，否则这种控制逻辑太复杂
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
