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