thread_pool_executor.hpp

// SPDX-License-Identifier: LGPL-2.1-or-later
 
#pragma once
 
#include <vitrio/concurrency/completion_notifier.hpp>
#include <vitrio/concurrency/executor.hpp>
#include <vitrio/concurrency/task.hpp>
#include <vitrio/export.hpp>
#include <vitrio/platform.hpp>
 
#include <cstddef>
#include <memory>
 
namespace vitrio
{
 
class VITRIO_API thread_pool_executor final
    : public executor
{
public:
    explicit thread_pool_executor(std::size_t worker_count);
 
    thread_pool_executor(const thread_pool_executor &other) = delete;
    thread_pool_executor(thread_pool_executor &&other) = delete;
 
    ~thread_pool_executor() override;
 
    thread_pool_executor&
    operator=(const thread_pool_executor &other) = delete;
    thread_pool_executor&
    operator=(thread_pool_executor &&other) = delete;
 
    std::size_t get_worker_count() const noexcept;
 
    void submit(
        std::unique_ptr<task> t,
        std::shared_ptr<completion_notifier> notifier
    ) override;
 
private:
    class implementation;
    VITRIO_STD_MEMBER_INTERFACE
    std::unique_ptr<implementation> m_implementation;
};
 
} // namespace vitrio