Method barrier

valdi_core/src/valdi_core/cpp/Threading/TaskQueue.cpp:128–153

}

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

    std::unique_lock<Mutex> lockGuard(_mutex);
    auto id = insertTask(DispatchFunction(), executeTime, true);

    while (!_tasks.empty()) {
        // Wait until we have no currently running tasks, and that the task at the front is our barrier task
        if (_currentRunningTasks != 0 || _tasks.front().id != id) {
            _condition.wait(lockGuard);
            continue;
        }

        // We have no running tasks, and our barrier task is at the front.
        // We can now execute our barrier
        _currentRunningTasks++;
        lockGuard.unlock();
        function();
        lockGuard.lock();
        auto toDelete = lockFreeRemoveTask(id);
        _currentRunningTasks--;
        lockGuard.unlock();
        _condition.notifyAll();
        return;
    }
}

DispatchFunction TaskQueue::nextTask(std::chrono::steady_clock::time_point maxTime, bool* shouldRun) {
    std::unique_lock<Mutex> lockGuard(_mutex);