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. More...
	~JPlatypus ()
	Destructor. More...

Static Public Attributes
static JQuantile	Q
	chi2/NDF More...

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 32 of file JPlatypus_t.hh.

Member Typedef Documentation

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

Definition at line 35 of file JPlatypus_t.hh.

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

Definition at line 36 of file JPlatypus_t.hh.

Constructor & Destructor Documentation

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 48 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));
      }
    }

JACOUSTICS::JPlatypus::~JPlatypus ( )

inline

Destructor.

Definition at line 117 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

JQuantile JACOUSTICS::JPlatypus::Q

static

chi2/NDF

Definition at line 134 of file JPlatypus_t.hh.

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

private

Definition at line 137 of file JPlatypus_t.hh.

input_type& JACOUSTICS::JPlatypus::input

private

Definition at line 138 of file JPlatypus_t.hh.

std::mutex JACOUSTICS::JPlatypus::in

private

Definition at line 139 of file JPlatypus_t.hh.

std::mutex JACOUSTICS::JPlatypus::out

private

Definition at line 140 of file JPlatypus_t.hh.

std::condition_variable JACOUSTICS::JPlatypus::cv

private

Definition at line 141 of file JPlatypus_t.hh.

bool JACOUSTICS::JPlatypus::stop

private

Definition at line 142 of file JPlatypus_t.hh.

---

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

• JPlatypus_t.hh
• JPlatypus_t.cc