PriorInference.h

Go to the documentation of this file.

#pragma once

#include "Control.h"
#include <queue>
#include <thread>

#include "ThreadedInferenceInterface.h"

template<typename HYP>
class PriorInference : public ThreadedInferenceInterface<HYP> {

public:
    
    typename HYP::Grammar_t* grammar;
    typename HYP::data_t* data;
    HYP* from;
    
    PriorInference(typename HYP::Grammar_t* g, typename HYP::data_t* d, HYP* fr=nullptr) : 
        grammar(g), data(d), from(fr) {
    }
    
    generator<HYP&> run_thread(Control& ctl) override {

        ctl.start();
        while(ctl.running()) {
            HYP h;
            if(from != nullptr) {
                h = *from; // copy 
                h.complete();
            }
            else {
                h = MyHypothesis::sample();
            }
            h.compute_posterior(*data);
            co_yield h;
        }
    }
};