Active.h

Go to the documentation of this file.

#pragma once
#include <functional>
#include <thread>
#include <atomic>
#include <scl/async/Channel.h>


namespace scl{
    namespace async{
        class Active{
            public:
                using message_type = std::function<void()>;

                using thread_type = std::thread;

                using flag_type = std::atomic_bool;

                using message_queue_type = Channel<message_type>;

            protected:
                flag_type done;

                message_queue_type mq;

                thread_type thread;

            public:
                Active() : done{false}, mq{}, thread{[=]{
                    while(!done){
                        auto message = mq.receiver().receive();
                        message();
                    }
                }} {}

                ~Active(){
                    this->execute([=]{
                        done = true;
                    });

                    this->thread.join();
                }

                void execute(message_type msg){
                    if(done)
                        return;

                    this->mq.sender().send(msg);
                }
        };
    }
}