Method Dispatch

Source/Engine/StratusThread.cpp:57–81

    }

    void Thread::Dispatch() {
        {
            std::unique_lock<std::mutex> ul(mutex_);

            // If we're still processing a previous dispatch, don't try to process another
            if (processing_.load()) return;
            
            // If nothing to process, return early
            if (frontQueue_.size() == 0) return;

            // Copy contents of front buffer to back buffer for processing
            for (const auto & func : frontQueue_) backQueue_.push_back(func);
            frontQueue_.clear();

            // Signal ready for processing
            processing_.store(true);
        }

        // If we don't own the context, use the current thread
        if (!ownsExecutionContext_) {
            SetCurrentThread(this);
            ProcessNext_();
            NullifyCurrentThread();
        }
    }

    void Thread::DispatchAndSynchronize() {
        Dispatch();