processing_handler.h

Go to the documentation of this file.

#pragma once

 
#include "handler.h"
#include <thread>
 
namespace satdump
{
    namespace handlers
    {
        class ProcessingHandler
        {
        public:
            ProcessingHandler() {}
            ~ProcessingHandler()
            {
                if (async_thread.joinable())
                    async_thread.join();
            }
 
        protected:
            bool is_processing = false;
            std::mutex is_processing_mtx;

            virtual void do_process() = 0;
 
            std::thread async_thread;
 
        public:
            void process()
            {
                is_processing_mtx.lock();
                is_processing = true;
                is_processing_mtx.unlock();
                do_process();
                is_processing_mtx.lock();
                is_processing = false;
                is_processing_mtx.unlock();
            }

            void set_is_processing(bool v)
            {
                is_processing_mtx.lock();
                is_processing = v;
                is_processing_mtx.unlock();
            }

            bool get_is_processing()
            {
                is_processing_mtx.lock();
                bool s = is_processing;
                is_processing_mtx.unlock();
                return s;
            }

            void asyncProcess()
            {
                is_processing_mtx.lock();
                if (is_processing && async_thread.joinable())
                {
                    printf("ALREADY PROCESSING!!!!\n"); // TODOREWORK
                    is_processing_mtx.unlock();
                    return;
                }
                is_processing_mtx.unlock();
 
                try
                {
                    async_thread.join();
                }
                catch (std::exception &e)
                {
                }
 
                is_processing_mtx.lock();
                is_processing = true;
                is_processing_mtx.unlock();
                auto fun = [this]() { process(); };
                async_thread = std::thread(fun);
            }
        };
    } // namespace handlers
} // namespace satdump