task_thread_pool.hxx

Go to the documentation of this file.

 
#pragma once
#include <ice/task_types.hxx>
#include <ice/mem_unique_ptr.hxx>
#include <ice/native_aio.hxx>
#include <ice/string.hxx>
#include <ice/span.hxx>
 
namespace ice
{
 
    struct TaskThreadPoolCreateInfo
    {
        ice::ncount thread_count = 0;

        ice::native_aio::AIOPort aioport = nullptr;

        ice::String debug_name_format = "ice.worker {}";
    };
 
    class TaskThreadPool
    {
    public:
        virtual ~TaskThreadPool() noexcept = default;
        virtual auto thread_count() const noexcept -> ice::ncount = 0;
        virtual auto managed_thread_count() const noexcept -> ice::ncount = 0;
        virtual auto estimated_task_count() const noexcept -> ice::ncount = 0;

        virtual auto create_thread(ice::StringID name) noexcept -> ice::TaskThread& = 0;

        virtual auto find_thread(ice::StringID name) noexcept -> ice::TaskThread* = 0;

        virtual bool destroy_thread(ice::StringID name) noexcept = 0;

        virtual auto attach_thread(
            ice::StringID name,
            //ice::TaskFlags accepting_flags,
            ice::UniquePtr<ice::TaskThread> thread
        ) noexcept -> ice::TaskThread& = 0;

        virtual auto detach_thread(
            ice::StringID name
        ) noexcept -> ice::UniquePtr<ice::TaskThread> = 0;
    };
 
    auto create_thread_pool(
        ice::Allocator& alloc,
        ice::TaskQueue& queue,
        ice::TaskThreadPoolCreateInfo const& threadpool_info
    ) noexcept -> ice::UniquePtr<ice::TaskThreadPool>;
 
} // namespace ice