bgtask.h

Go to the documentation of this file.

/*
-------------------------------------------------------------------------------
                            PLEBBLE
-------------------------------------------------------------------------------
 Copyright (C) 2019-2020 KATLAS Technology. (http://katlastechnology.com)
 Copyright (C) 2017-2020 Marcos Mayorga. (mm@mm-studios.com)
 
 This file is part of our Plebble(R) Platform.
 
 The code below cannot be copied, used for any purpose other than the one
 agreed and/or distributed without the express permission of
 KATLAS Technology.
-------------------------------------------------------------------------------
 
 
*/
#ifndef USGOV_d9c2e31514229da73677728a36467d5093f9d8c21db0e4518775212f42272f6b
#define USGOV_d9c2e31514229da73677728a36467d5093f9d8c21db0e4518775212f42272f6b
 
#include <thread>
#include <atomic>
#include <condition_variable>
#include <mutex>
#include <functional>
#include <us/gov/config.h>
 
namespace us{ namespace gov {
 
    using namespace std;
 
    struct bgtask {
        bgtask();
        bgtask(function<void ()> run, function<void ()> onwakeup);
        virtual ~bgtask();
 
        static const char* KO_81021;
 
        void set_run_function(function<void ()> r);
        virtual ko start();
        virtual ko wait_ready(const chrono::system_clock::time_point& deadline) const;
        virtual void stop();
        virtual void join();
        void wakeup();
        bool isup() const { return resume.load()!=2; }
        bool isdown() const { return resume.load()==2; }
        //bool is_ready() const { return ready; }
        bool resumed() const { return resume.load()>0; }
        void run_();
        void reset() { resume.store(0); }
        bool reset_wait();
        bool reset_resume();
        inline bool is_active() const { return active; }
 
    protected:
        atomic<short> resume{0};
        thread* th{nullptr};
        bool active{false};
 
        function<void ()> run;
        function<void ()> onwakeup;
 
        mutable mutex mx_ready;
        bool ready{false};
        mutable condition_variable cv_ready;
    };
 
    struct wbgtask: bgtask {
        typedef bgtask b;
        wbgtask(function<void ()> onwakeup);
        virtual ~wbgtask();
 
        virtual void collect()=0;
        virtual void task_init() {};
        virtual void task()=0;
        virtual void task_cleanup() {};
 
        private:
        void collect_();
        void run();
    };
 
 
}}
 
#endif