Method RunTask

executor/lib/generic_dev_executor.cpp:291–336

}

bool GenericDevExecutor::RunTask(SubgraphTask* task)
{
    // return true: accepted running
    // return false: try again

    if(DevGetStatus() != kDevNormal)
    {
        task->SetStatus(EXEC_STATUS_READY);
        InsertQueue(task);
        return false;
    }

    if(SupportNonblockRun())
    {
        task->Lock();    // protect with OnSubgraphDone()

        bool ret = DevRun(task->graph_handle);

        if(ret)
            task->SetStatus(EXEC_STATUS_RUN);
        else
            task->SetStatus(EXEC_STATUS_READY);

        InsertQueue(task);

        task->Unlock();

        return ret;
    }
    else
    {
        task->Lock();    // protect with Postrun()

        bool ret = DevSyncRun(task->graph_handle);

        task->SetStatus(EXEC_STATUS_WAIT);

        InsertQueue(kWaitQueue, task);

        task->OnTaskDone(ret);

        task->Unlock();

        return ret;
    }
}

bool GenericDevExecutor::PostrunTask(SubgraphTask* task)
{