Method remove_node_task

bmf/engine/c_engine/src/scheduler_queue.cpp:66–82

}

int SchedulerQueue::remove_node_task(int node_id) {
    std::lock_guard<std::mutex> guard(con_var_mutex_);
    SafePriorityQueue<Item> temp_queue;
    while (!queue_.empty()) {
        Item item;
        queue_.pop(item);
        if (item.task.node_id_ != node_id) {
            temp_queue.push(item);
        }
    }
    while (!temp_queue.empty()) {
        Item item;
        temp_queue.pop(item);
        queue_.push(item);
    }
    return 0;
}

int SchedulerQueue::exec_loop() {
    while (true) {