PeriodicService.h

Go to the documentation of this file.

#pragma once

#include <swarmio/Mailbox.h>
#include <thread>

namespace swarmio::services
{
    class PeriodicService : public Mailbox
    {
        private:

            std::thread* _worker = nullptr;

            std::atomic<bool> _shutdownRequested;

            std::chrono::milliseconds _period;

            void Worker();

        protected:

            PeriodicService(Endpoint* endpoint, std::chrono::milliseconds period)
                : Mailbox(endpoint), _shutdownRequested(false), _period(period), _worker(nullptr) { }

            virtual void MailboxWasConnected() noexcept override;

            virtual void MailboxWillBeDisconnected() noexcept override;

            virtual void Update() = 0;
    };
}