Method PopQueue

executor/lib/generic_dev_executor.cpp:111–142

    return ret;
}
SubgraphTask* GenericDevExecutor::PopQueue(QueueType queue_type)
{
    std::mutex* p_mutex = nullptr;
    task_queue_t* p_queue = nullptr;

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

    Lock(*p_mutex);

    auto ir = p_queue->begin();

    if(ir == p_queue->end())
    {
        Unlock(*p_mutex);
        return nullptr;
    }

    auto set_ir = ir->second.begin();

    SubgraphTask* task = *set_ir;

    ir->second.erase(set_ir);

    if(ir->second.empty())
    {
        p_queue->erase(ir);
    }

    Unlock(*p_mutex);
    return task;
}
int GenericDevExecutor::GetElementNumber(QueueType queue_type)
{
    std::mutex* p_mutex;