Method joinAllThreads

Disruptor.Tests/StubExecutor.cpp:28–52

    }

    void StubExecutor::joinAllThreads()
    {
        std::lock_guard< decltype(m_mutex) > lock(m_mutex);

        while (!m_threads.empty())
        {
            boost::thread thread(std::move(m_threads.front()));
            m_threads.pop_front();

            if (thread.joinable())
            {
                try
                {
                    thread.interrupt();
                    thread.timed_join(boost::posix_time::milliseconds(5000));
                }
                catch (std::exception& ex)
                {
                    std::cout << ex.what() << std::endl;
                }
            }

            BOOST_CHECK_MESSAGE(thread.joinable() == false, "Failed to stop thread: " << thread.get_id());
        }
    }

    void StubExecutor::ignoreExecutions()
    {