Method lockFreeRemoveTask

valdi_core/src/valdi_core/cpp/Threading/TaskQueue.cpp:116–126

}

DispatchFunction TaskQueue::lockFreeRemoveTask(task_id_t taskId) {
    for (auto i = _tasks.begin(); i != _tasks.end(); ++i) {
        if (i->id == taskId) {
            auto task = std::move(*i);
            _tasks.erase(i);
            return std::move(task.function);
        }
    }

    return DispatchFunction();
}

void TaskQueue::barrier(const DispatchFunction& function) {
    auto executeTime = std::chrono::steady_clock::now();