ThreadPool.hpp

Go to the documentation of this file.

/*
** EPITECH PROJECT, 2025
** Created by hugo on 06/12/2025
** File description:
** ThreadPool.hpp
*/
 
#pragma once
 
#include <thread>
#include "common/Threading/ThreadSafeQueue.hpp"
#include "server/Core/ThreadPool/IThreadPool.hpp"
 
namespace server {
 
    class ThreadPool : public IThreadPool {
       public:
        explicit ThreadPool(size_t threadCount);
        ~ThreadPool() override;
 
        void enqueue(Task task) override;
        void start() override;
        void stop() override;
        size_t size() const override;
 
       private:
        void _workerLoop(std::stop_token stopToken);
 
        size_t _threadCount;
        std::vector<std::jthread> _workers;
        ThreadSafeQueue<Task> _taskQueue;
    };
 
}  // namespace server