Method endBatch

valdi/src/valdi/runtime/Utils/MainThreadManager.cpp:148–182

}

void MainThreadManager::endBatch() {
    size_t flushId;

    // See if we are the last endBatch() call, otherwise decrement the batchCount
    {
        std::lock_guard<std::mutex> lockGuard(_mutex);
        SC_ASSERT(_batchCount > 0, "Unbalanced beginBatch() endBatch() call");
        if (_batchCount > 1) {
            // Only the last endBatch() call will flush the TaskQueue
            _batchCount--;
            return;
        }

        flushId = _batchFlushId;
        // Increase flush id sequence, so that if there is a beginBatch() call
        // that occurs while we are flushing the tasks of this batch, the tasks
        // will be flushed on the next main thread tick.
        _flushIdSequence++;
    }

    // Flush all pending tasks.
    flushTasksWithId(flushId);

    // Disable batching
    std::lock_guard<std::mutex> lockGuard(_mutex);
    SC_ASSERT(_batchCount == 1, "Unbalanced beginBatch() endBatch() call");
    _batchCount = 0;

    if (flushId != _batchFlushId) {
        // Our batch flush id changed, which means that a main thread batch task
        // has been enqueued while we were flushing the tasks. We should flush
        // them on the next main thread tick.
        scheduleFlush(_batchFlushId, false);
    }
}

void MainThreadManager::onIdle(const Ref<ValueFunction>& callback) {
    std::lock_guard<std::mutex> lockGuard(_mutex);