task_scoped_container.hxx

Go to the documentation of this file.

 
#pragma once
#include <ice/task_container.hxx>
#include <ice/array.hxx>
#include <ice/sync_manual_events.hxx>
 
namespace ice
{
 
    class ScopedTaskContainer : public TaskContainer
    {
    public:
        ScopedTaskContainer(ice::Allocator& alloc) noexcept;
        ~ScopedTaskContainer() noexcept;

        auto create_tasks(
            ice::u32 count,
            ice::ShardID shardid
        ) noexcept -> ice::Span<ice::Task<>> override;
 
        auto await_tasks_scheduled_on(ice::TaskScheduler& scheduler, ice::TaskScheduler& resumer) noexcept -> ice::Task<> override;

        auto execute_tasks() noexcept -> ice::u32 override;

        auto running_tasks() const noexcept -> ice::u32 override;

        void wait_tasks() noexcept override;
 
        auto extract_tasks() noexcept -> ice::Array<ice::Task<>> override;
 
    private:
        ice::Allocator& _allocator;
        ice::Array<ice::Task<>> _tasks;
        ice::ManualResetBarrier _barrier;
    };
 
} // namespace ice