AsioContext.h

Go to the documentation of this file.

//
// Created by Louis Grignon on 27/08/2025.
//
 
#ifndef ASIOCONTEXT_H
#define ASIOCONTEXT_H
 
#include <CscCommon.h>
#include <thread>
 
namespace boost::asio {
class io_context;
}
 
namespace conscience_core::communication {
class AsioContext {
public:
    AsioContext(size_t nbThreads = 1);
 
    virtual ~AsioContext();
    boost::asio::io_context *const context;
 
    void stopActivity();
 
private:
    size_t nbThreads;
    std::vector<std::thread> workers;
    std::atomic_bool stopping = false;
    void ioRunLoop(size_t workerId) const;
};
 
AsioContext *getSharedAsioContext();
 
}
#endif //ASIOCONTEXT_H