Function test_multithreaded

test/so_dll_test.cpp:144–216

}

void test_multithreaded()
{
    constexpr int N = 100;
    {
        std::mutex mtx;
        std::condition_variable cv;
        bool ready = false;
        auto test_function = [&]
        {
            std::unique_lock<std::mutex> lock(mtx);
            cv.wait(lock, [&]{ return ready; });
            lock.unlock();
            int result1 = test_result(hidden_result1, false);
            int result2 = test_result(hidden_result2, false);
            return result1 + result2;
        };
        std::vector<std::future<int>> futures;
        for (int i = 0; i < N; ++i)
            futures.push_back(std::async(std::launch::async, test_function));
        {
            std::lock_guard<std::mutex> lock(mtx);
            ready = true;
        }
        cv.notify_all();
        for (auto start = std::chrono::steady_clock::now(); std::chrono::steady_clock::now() - start < std::chrono::seconds(1); )
            if ((std::rand() % 2) == 0 || futures.empty())
                futures.push_back(std::async(std::launch::async, test_function));
            else
            {
                BOOST_TEST_EQ(futures.back().get(), 0);
                futures.pop_back();
            }
        for (auto & f : futures)
            BOOST_TEST_EQ(f.get(), 0);
    }

#ifndef BOOST_LEAF_NO_EXCEPTIONS
    {
        std::mutex mtx;
        std::condition_variable cv;
        bool ready = false;
        auto test_function = [&]
        {
            std::unique_lock<std::mutex> lock(mtx);
            cv.wait(lock, [&]{ return ready; });
            lock.unlock();
            int result1 = test_exception(hidden_throw1, false);
            int result2 = test_catch(hidden_throw1);
            int result3 = test_exception(hidden_throw2, false);
            int result4 = test_catch(hidden_throw2);
            return result1 + result2 + result3 + result4;
        };
        std::vector<std::future<int>> futures;
        for (int i = 0; i < N; ++i)
            futures.push_back(std::async(std::launch::async, test_function));
        {
            std::lock_guard<std::mutex> lock(mtx);
            ready = true;