CodingHanYa / workspace

workspace是基于C++11的轻量级异步执行框架,支持:通用任务异步并发执行、优先级任务调度、自适应动态线程池、高效静态线程池、异常处理机制等。
Apache License 2.0
916 stars 136 forks source link

if (enable_steal_tasks) 的意义 #8

Open Crowbar1024 opened 1 year ago

Crowbar1024 commented 1 year ago

如果能执行到worker中的 if (enable_steal_tasks) 的代码块,意味着waiting=false,但这又意味着全部任务执行完了,这个时候从其他线程的工作队列拿任务的意义何在?不是全部任务已经没了吗?求懂哥解释

CodingHanYa commented 1 year ago

没有维护一个全局任务数,所以线程也无法知道其它线程是否还有任务,只能先去搜索。如果没搜索到,再通知CPU切换到其它线程执行。

Crowbar1024 commented 1 year ago
void waitForTasks() {
    for (int i = 0; i < thread_numb; ++i) {
        threads[i].waitTasksDone();
    }
    for (int i = 0; i < thread_numb; ++i) {
       threads[i].cleanWaitingFlag();
    }
}

对这段代码我的理解是:如果某个线程的waiting==false,那么该pond的所有线程的任务数已经为0了。那么怎么去偷窃呢?

CodingHanYa commented 1 year ago

我不太能理解你想表达的 { '_' }