thpool.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_d0f4984484ed32b47236bc469d4f4ff73f9374b168d6bb224f3e3dd6d255c249
#define USGOV_d0f4984484ed32b47236bc469d4f4ff73f9374b168d6bb224f3e3dd6d255c249
 
#include <thread>
#include <vector>
#include <unordered_set>
#include <us/gov/config.h>
#include <condition_variable>
#include <mutex>
#include <atomic>
 
namespace us { namespace gov {
namespace socket {
    using namespace std;
 
    struct peer_t;
    struct daemon;
 
    struct thpool final:vector<thread*> {
        thpool(daemon*d);
        ~thpool();
        ko start(size_t sz);
        ko wait_ready(const chrono::system_clock::time_point& deadline) const;
        void stop();
        void join();
        void process(peer_t*p);
        void run();
        void watch(ostream&) const;
 
        unordered_set<peer_t*> q;
        condition_variable cv;
        mutable mutex mx_q;
        daemon* d;
        #if CFG_COUNTERS==1
            struct counters_t {
                uint32_t jobs_queued{0};
                atomic<uint32_t> jobs_dispatched{0};
                void dump(ostream& os) const;
            };
            counters_t counters;
        #endif
        atomic<short> resume{0};
        mutex mx;
        #if CFG_LOGS==1
            string logdir;
        #endif
    };
 
}
}}
 
#endif