JACOUSTICS::JPlatypus Class Reference

Thread pool for global fits using super events. More...

#include <JPlatypus_t.hh>

Public Types
typedef JTOOLS::JHashMap< int, JEmitter >	JEmitters
typedef JLANG::JObjectIterator< JSuperEvt >	input_type

Public Member Functions
	JPlatypus (const JGeometry &geometry, const JEmitters &emitters, const JSoundVelocity &velocity, const JFitParameters &parameters, input_type &input, const size_t ns)
	Constructor.
	~JPlatypus ()
	Destructor.

Static Public Attributes
static JMATH::JQuantile_t	Q
	chi2/NDF

Private Attributes
std::vector< std::thread >	workers
input_type &	input
std::mutex	in
std::mutex	out
std::condition_variable	cv
bool	stop

Detailed Description

Thread pool for global fits using super events.

Definition at line 34 of file JPlatypus_t.hh.

Member Typedef Documentation

JEmitters

JTOOLS::JHashMap<int, JEmitter> JACOUSTICS::JPlatypus::JEmitters

Definition at line 37 of file JPlatypus_t.hh.

input_type

JLANG::JObjectIterator<JSuperEvt> JACOUSTICS::JPlatypus::input_type

Definition at line 38 of file JPlatypus_t.hh.

Constructor & Destructor Documentation

JPlatypus()

JACOUSTICS::JPlatypus::JPlatypus ( const JGeometry & geometry, const JEmitters & emitters, const JSoundVelocity & velocity, const JFitParameters & parameters, input_type & input, const size_t ns )

inline

Constructor.

Parameters

geometry	detector geometry
emitters	emitters geometry
velocity	sound velocity
parameters	parameters
input	input
ns	number of threads

Definition at line 50 of file JPlatypus_t.hh.

                                        :
      input(input),
      stop(false)
    {
      using namespace std;
      using namespace JPP;
 
      Q.reset();
 
      for (size_t i = 0; i < ns; ++i) {
 
        thread worker([this, geometry, emitters, velocity, parameters]() {
 
          vector<JHit> data;
 
          for (JKatoomba<JGandalf> katoomba(geometry, velocity, parameters.option); ; ) {
 
            katoomba.estimator.reset(getMEstimator(parameters.mestimator));
 
            {
              unique_lock<mutex> lock(in);
 
              cv.wait(lock, [this]() { return stop || this->input.hasNext(); });
 
              if (stop && !this->input.hasNext()) {
                return;
              }
 
              const JSuperEvt* evt = this->input.next();
 
              data.clear();
              
              for (JSuperEvt::rx_type::const_iterator hit = evt->rx.begin(); hit != evt->rx.end(); ++hit) {
                
                data.push_back(JHit(emitters[hit->id],
                                    hit->counter,
                                    JLocation(hit->string, hit->floor),
                                    hit->toa,
                                    parameters.sigma_s,
                                    hit->weight));
              }
 
              katoomba.value = getModel(*evt);
            }
 
            const double chi2 = katoomba (data.begin(), data.end()) / katoomba.estimator->getRho(1.0);
            const double ndf  = getWeight(data.begin(), data.end()) - katoomba.value.getN();
 
            {
              unique_lock<mutex> lock(out);
 
              Q.put(chi2 / ndf);
            }
          }
        });
 
        workers.emplace_back(std::move(worker));
      }
    }

~JPlatypus()

JACOUSTICS::JPlatypus::~JPlatypus ( )

inline

Destructor.

Definition at line 119 of file JPlatypus_t.hh.

    {
      using namespace std;
 
      {
        unique_lock<mutex> lock(in);
 
        stop = true;
      }
      
      cv.notify_all();
 
      for (auto& worker : workers) {
        worker.join();
      }
    }

Member Data Documentation

Q

JMATH::JQuantile_t JACOUSTICS::JPlatypus::Q

static

chi2/NDF

Definition at line 136 of file JPlatypus_t.hh.

workers

std::vector<std::thread> JACOUSTICS::JPlatypus::workers

private

Definition at line 139 of file JPlatypus_t.hh.

input

input_type& JACOUSTICS::JPlatypus::input

private

Definition at line 140 of file JPlatypus_t.hh.

in

std::mutex JACOUSTICS::JPlatypus::in

private

Definition at line 141 of file JPlatypus_t.hh.

out

std::mutex JACOUSTICS::JPlatypus::out

private

Definition at line 142 of file JPlatypus_t.hh.

cv

std::condition_variable JACOUSTICS::JPlatypus::cv

private

Definition at line 143 of file JPlatypus_t.hh.

stop

bool JACOUSTICS::JPlatypus::stop

private

Definition at line 144 of file JPlatypus_t.hh.

---

The documentation for this class was generated from the following files:

• JPlatypus_t.hh
• JPlatypus_t.cc