threadpool_tests.cpp

#include <atomic>
#include <cstddef>
#include <gtest/gtest.h>


#include "cpr/threadpool.h"

TEST(ThreadPoolTests, DISABLED_BasicWorkOneThread) {
    std::atomic_uint32_t invCount{0};
    uint32_t invCountExpected{100};

    {
        cpr::ThreadPool tp;
        tp.SetMinThreadNum(1);
        tp.SetMaxThreadNum(1);
        tp.Start(0);

        for (size_t i = 0; i < invCountExpected; ++i) {
            tp.Submit([&invCount]() -> void { invCount++; });
        }

        // Wait for the thread pool to finish its work
        tp.Wait();
    }

    EXPECT_EQ(invCount, invCountExpected);
}

TEST(ThreadPoolTests, DISABLED_BasicWorkMultipleThreads) {
    std::atomic_uint32_t invCount{0};
    uint32_t invCountExpected{100};

    {
        cpr::ThreadPool tp;
        tp.SetMinThreadNum(1);
        tp.SetMaxThreadNum(10);
        tp.Start(0);

        for (size_t i = 0; i < invCountExpected; ++i) {
            tp.Submit([&invCount]() -> void { invCount++; });
        }

        // Wait for the thread pool to finish its work
        tp.Wait();
    }

    EXPECT_EQ(invCount, invCountExpected);
}

TEST(ThreadPoolTests, DISABLED_PauseResumeSingleThread) {
    std::atomic_uint32_t invCount{0};

    uint32_t repCount{100};
    uint32_t invBunchSize{20};

    cpr::ThreadPool tp;
    tp.SetMinThreadNum(1);
    tp.SetMaxThreadNum(10);
    tp.Start(0);

    for (size_t i = 0; i < repCount; ++i) {
        tp.Pause();
        EXPECT_EQ(invCount, i * invBunchSize);

        for (size_t e = 0; e < invBunchSize; ++e) {
            tp.Submit([&invCount]() -> void { invCount++; });
        }
        tp.Resume();
        // Wait for the thread pool to finish its work
        tp.Wait();

        EXPECT_EQ(invCount, (i + 1) * invBunchSize);
    }
}

TEST(ThreadPoolTests, DISABLED_PauseResumeMultipleThreads) {
    std::atomic_uint32_t invCount{0};

    uint32_t repCount{100};
    uint32_t invBunchSize{20};

    cpr::ThreadPool tp;
    tp.SetMinThreadNum(1);
    tp.SetMaxThreadNum(10);
    tp.Start(0);

    for (size_t i = 0; i < repCount; ++i) {
        tp.Pause();
        EXPECT_EQ(invCount, i * invBunchSize);

        for (size_t e = 0; e < invBunchSize; ++e) {
            tp.Submit([&invCount]() -> void { invCount++; });
        }
        tp.Resume();
        // Wait for the thread pool to finish its work
        tp.Wait();

        EXPECT_EQ(invCount, (i + 1) * invBunchSize);
    }
}


int main(int argc, char** argv) {
    ::testing::InitGoogleTest(&argc, argv);
    return RUN_ALL_TESTS();
}