main.cpp

#include <ichor/event_queues/PriorityQueue.h>
#include <ichor/DependencyManager.h>
#include <ichor/services/timer/TimerFactoryFactory.h>
#include <csignal>

using namespace Ichor;

std::atomic<bool> quit{};

void siginthandler(int) {
    quit = true;
}

class SigIntService final {
public:
    SigIntService(ITimerFactory *factory) {
        // Setup a timer that fires every 100 milliseconds
        auto &timer = factory->createTimer();
        timer.setChronoInterval(100ms);

        timer.setCallback([]() {
            // If sigint has been fired, send a quit to the event loop.
            // This can't be done from within the siginthandler itself, as the mutex surrounding pushEvent might already be locked, resulting in a deadlock!
            if(quit) {
                GetThreadLocalEventQueue().pushEvent<QuitEvent>(0);
            }
        });
        timer.startTimer();

        // Register sigint handler
        auto r = ::signal(SIGINT, siginthandler);
        if(r == SIG_ERR) {
            std::terminate();
        }
    }
};

int main(int argc, char *argv[]) {
    std::locale::global(std::locale("en_US.UTF-8")); // some loggers require having a locale

    auto queue = std::make_unique<PriorityQueue>();
    auto &dm = queue->createManager();

    dm.createServiceManager<SigIntService>();
    dm.createServiceManager<TimerFactoryFactory>();

    // Start manager, consumes current thread.
    queue->start(DoNotCaptureSigInt);

    return 0;
}