EventLoopGroup.h

Go to the documentation of this file.

#pragma once

#include <aws/crt/Types.h>

#include <aws/io/event_loop.h>

#include <chrono>
#include <functional>
#include <memory>

namespace Aws
{
    namespace Crt
    {
        namespace Io
        {
            enum class TaskStatus
            {
                RunReady,
                Canceled,
            };

            class AWS_CRT_CPP_API ScheduledTask final
            {
              public:
                ScheduledTask() noexcept = default;

                void Cancel() noexcept;

              private:
                class Impl;

                explicit ScheduledTask(std::shared_ptr<Impl> impl) noexcept;

                std::shared_ptr<Impl> m_impl;

                friend class EventLoop;
            };

            class AWS_CRT_CPP_API EventLoop final
            {
              public:
                explicit operator bool() const noexcept { return m_loop != nullptr; }

                ScheduledTask Schedule(
                    std::function<void(TaskStatus)> &&task,
                    std::chrono::nanoseconds run_in) noexcept;

              private:
                explicit EventLoop(aws_event_loop *loop) noexcept;

                aws_event_loop *m_loop;

                friend class ClientBootstrap;
            };

            class AWS_CRT_CPP_API EventLoopGroup final
            {
              public:
                EventLoopGroup(uint16_t threadCount = 0, Allocator *allocator = ApiAllocator()) noexcept;
                EventLoopGroup(uint16_t cpuGroup, uint16_t threadCount, Allocator *allocator = ApiAllocator()) noexcept;
                ~EventLoopGroup();
                EventLoopGroup(const EventLoopGroup &) = delete;
                EventLoopGroup(EventLoopGroup &&) noexcept;
                EventLoopGroup &operator=(const EventLoopGroup &) = delete;
                EventLoopGroup &operator=(EventLoopGroup &&) noexcept;

                operator bool() const;

                int LastError() const;

                aws_event_loop_group *GetUnderlyingHandle() noexcept;

              private:
                aws_event_loop_group *m_eventLoopGroup;
                int m_lastError;
            };
        } // namespace Io

    } // namespace Crt
} // namespace Aws