Method SyncRun

executor/lib/graph_task.cpp:249–312

}

bool GraphTask::SyncRun(void)
{
    if(status_ != EXEC_STATUS_INITED && status_ != EXEC_STATUS_READY)

    {
        XLOG_ERROR() << "bad status: " << dev_engine_->GetStatusStr(status_) << "\n";
        return false;
    }

    status_ = EXEC_STATUS_RUN;
    output_wait_count_ = output_task_number_ * 2;    // never signal graph task done
    active_sub_task_count_ = 0;

    std::set<SubgraphTask*> working_set;

    for(unsigned int i = 0; i < sub_task_list_.size(); i++)
        working_set.insert(sub_task_list_[i]);

    // first try: sequentially execution
    for(unsigned int j = 0; j < sub_task_list_.size(); j++)
    {
        SubgraphTask* sub_task = sub_task_list_[j];

        if(!sub_task->input_wait_count_)
        {
            bool ret = SyncRunSubgraphTask(sub_task);
            if(ret)
                working_set.erase(sub_task);
            else
            {
                status_ = EXEC_STATUS_BAD;
                return false;
            }
        }
    }

    // second round: repeatly try the tasks in working_set

    while(!working_set.empty())
    {
        for(auto ir = working_set.begin(); ir != working_set.end();)
        {
            SubgraphTask* sub_task = *ir;

            if(sub_task->input_wait_count_)
                ir++;
            else
            {
                if(SyncRunSubgraphTask(sub_task))
                {
                    ir = working_set.erase(ir);
                }
                else
                {
                    status_ = EXEC_STATUS_BAD;
                    return false;
                }
            }