Async policy for job multiplexing on worker side. More...
#include "datatype/datatypes.hpp"
#include "comms/worker.hpp"
#include "comms/delegator.hpp"
#include "comms/requester.hpp"
#include "comms/minion.hpp"
#include "fwdmodel/fwd.hpp"
#include "likelihood/likelihood.hpp"
#include "serial/serial.hpp"
Namespaces | |
obsidian | |
Functions | |
template<ForwardModel f> | |
bool | obsidian::workerThread (const typename Types< f >::Spec &spec, const typename Types< f >::Cache &cache, const typename Types< f >::Results &real, stateline::comms::Worker &worker) |
Thread method receives jobs and evaluates likelihoods and sends results back until until interrupted by signal. | |
Async policy for job multiplexing on worker side.