Function GetNextThreadIndexForTask_

Source/Engine/StratusTaskSystem.h:93–115

        }

        size_t GetNextThreadIndexForTask_() {
            if (taskThreads_.size() == 0) throw std::runtime_error("Task threads size equal to 0");

            // Enter the threads with their current number of work items in a list
            bool found = false;
            const auto currentId = Thread::Current().Id();
            std::vector<std::pair<ThreadHandle, size_t>> currentWorkLoads;
            currentWorkLoads.reserve(threadToIndexMap_.size());
            for (const auto& entry : threadToIndexMap_) {
                if (entry.first == currentId) continue;
                currentWorkLoads.push_back(std::make_pair(entry.first, threadsWorking_[entry.second]->load()));
            }

            const auto comparison = [](const std::pair<ThreadHandle, size_t>& a, const std::pair<ThreadHandle, size_t>& b) {
                return a.second < b.second;
            };

            // Sort the threads based on how much work they currently have
            std::sort(currentWorkLoads.begin(), currentWorkLoads.end(), comparison);
            
            // Choose the first which should have the least work items
            return threadToIndexMap_.find(currentWorkLoads[0].first)->second;
        }

        template<typename E, typename T>
        Async<E> ScheduleTask_(const T& process) {