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.