event_thread.h

Go to the documentation of this file.

// Evo C++ Library
/* Copyright 2019 Justin Crowell
Distributed under the BSD 2-Clause License -- see included file LICENSE.txt for details.
*/

#pragma once
#ifndef INCL_evo_event_thread_h
#define INCL_evo_event_thread_h

#include "event.h"
#include "thread.h"

namespace evo {


struct EventThreadState {
    EventQueue<> queue;     
    Condition condmutex;    
    AtomicInt shutdown;     
    ulong waitms;           
};

class EventThreadPool : public ThreadGroup<Thread,EventThreadState> {
public:
    typedef EventThreadPool This;   

    EventThreadPool(ulong wait_timeout_ms=1) : ThreadGroup<Thread,EventThreadState>(thread_run) {
        shared_state.waitms = wait_timeout_ms;
    }

    This& add(Event* event, ulongl spinwait_ns=1) {
        shared_state.queue.add(event, spinwait_ns);
        shared_state.queue.notify_multiwait(shared_state.condmutex);
        return *this;
    }

    This& shutdown() {
        shared_state.shutdown.store(1, EVO_ATOMIC_RELEASE);
        shared_state.condmutex.lock_notify_all();
        return *this;
    }

private:
    typedef ThreadGroup<Thread,EventThreadState> Base;

    Base& cancel() EVO_ONCPP11(= delete);
    bool cancelled() const EVO_ONCPP11(= delete);

    static void thread_run(void* arg) {
        EventThreadState& state = *(EventThreadState*)arg;
        const ulong waitms = state.waitms;
        while (state.shutdown.load(EVO_ATOMIC_ACQUIRE) == 0)
            state.queue.process_multiwait(state.condmutex, state.shutdown, waitms);
        while (state.queue.process_multi(state.condmutex));
    }
};


}
#endif