pool.cpp

/*
    SPDX-License-Identifier: MIT
    Copyright © 2023-2024 Amebis
*/
 
#include "pch.hpp"
 
using namespace std;
#ifdef _WIN32
using namespace Microsoft::VisualStudio::CppUnitTestFramework;
#endif
 
namespace UnitTests
{
    constexpr size_t pool_capacity = 50;
 
    TEST_CLASS(pool)
    {
    public:
        TEST_METHOD(test)
        {
            using worker_t = unique_ptr<int>;
            using pool_t = stdex::pool<worker_t>;
            pool_t pool;
            list<thread> workers;
            for (auto n = thread::hardware_concurrency(); n--; ) {
                workers.push_back(thread([](_Inout_ pool_t& pool)
                {
                    for (size_t n = 10000; n--; ) {
                        worker_t el = pool.pop();
                        if (!el)
                            el.reset(new int(1));
                        pool.push(std::move(el));
                    }
                }, ref(pool)));
            }
 
            for (auto& w : workers)
                w.join();
        }
    };
}