Method InsertQueue

executor/lib/generic_dev_executor.cpp:55–81

}

void GenericDevExecutor::InsertQueue(GenericDevExecutor::QueueType queue_type, SubgraphTask* task)
{
    std::mutex* p_mutex = nullptr;
    task_queue_t* p_queue = nullptr;

    if(!GetQueueReference(queue_type, p_mutex, p_queue))
        return;

    Lock(*p_mutex);

    // first one?

    auto ir = p_queue->find(task->exec_priority);

    if(ir == p_queue->end())
    {
        std::set<SubgraphTask*> set;
        set.insert(task);
        (*p_queue)[task->exec_priority] = set;
    }
    else
    {
        ir->second.insert(task);
    }

    Unlock(*p_mutex);
}
bool GenericDevExecutor::RemoveQueue(QueueType queue_type, SubgraphTask* task)
{
    std::mutex* p_mutex = nullptr;