Method workingLoop

Disruptor/RoundRobinThreadAffinedTaskScheduler.cpp:54–72

    }

    void RoundRobinThreadAffinedTaskScheduler::workingLoop(std::int32_t threadId)
    {
        static const auto processorCount = std::thread::hardware_concurrency();

        const auto processorIndex = threadId % processorCount;

        const auto affinityMask = ThreadHelper::AffinityMask(1ull << processorIndex);

        ThreadHelper::setThreadAffinity(affinityMask);

        while (m_started)
        {
            std::packaged_task< void() > task;
            while (m_tasks.timedWaitAndPop(task, std::chrono::milliseconds(100)))
            {
                tryExecuteTask(task);
            }
        }
    }

    void RoundRobinThreadAffinedTaskScheduler::tryExecuteTask(std::packaged_task< void() >& task)
    {